fFee-ops's Blog
linux配置JAVA_HOME linux配置JAVA_HOME
1、首先输入 echo $JAVA_HOME 看有没有输出。有的话证明已经配置了，没有就继续。 2、输入find / -name java找到JDK位置 3、复制选中的jdk的路径 4、vi /etc/profile 添加如下内容：
2022-02-05 Linux
kafka架构探索及安装 kafka架构探索及安装
1. 发展历程https://kafka.apache.org/downloads 1.1 版本命名Kafka在1.0.0版本前的命名规则是4位，比如0.8.2.1，0.8是大版本号，2是小版本号，1表示打过1个补丁。 现在的版本号命名规则
2022-02-05 kafka
kafka创建主题出错:zookeeper is not a recognized option kafka创建主题出错:zookeeper is not a recognized option
原因选项zookeeper已弃用 解决把选项zookeeper替换为--bootstrap-server来使用
2022-02-05 kafka
kafka基础组件 kafka基础组件
角色 broker：节点，就是你看到的机器，也就是一个kafka服务 provider：生产者，发消息的 consumer：消费者，读消息的 zookeeper：信息/注册中心，记录kafka的各种信息的地方 controller：其中的
2022-02-05 kafka
kafka简介 kafka简介
1. 应用场景1.1 kafka场景Kafka最初是由LinkedIn公司采用Scala语言开发，基于ZooKeeper，现在已经捐献给了Apache基金会。目前Kafka已经定位为一个分布式流式处理平台，它以 高吞吐、可持久化、可
2022-02-04 kafka
RocketMQ消费进度管理 RocketMQ消费进度管理
业务实现消费回调的时候，当且仅当此回调函数返回ConsumeConcurrentlyStatus.CONSUME_SUCCESS ，RocketMQ才会认为这批消息（默认是1条）是消费完成的 如果这时候消息消费失败，例如数据库异常，余额不足
2022-02-03 RocketMQ
RocketMQ业务保障 RocketMQ业务保障
1. 为什么从业务上保证1.1 消息丢失问题RocketMQ虽然号称消息不会丢失，但是还是有几率存在MQ宕机以及rocketMQ使用上的问题可能存在消息丢失等，对于类似于支付确认的消息一般来说是一条都不允许丢失的 1.2 消息幂等性在网络环
2022-02-03 RocketMQ
RocketMQ文件刷盘机制与过期文件删除 RocketMQ文件刷盘机制与过期文件删除
文件刷盘机制RocketMQ 的消息是存储在磁盘上的，这样做有两个优点： 保证断电后恢复 让存储的消息量超出内存的限制 RocketMQ 存储与读写是基于 JDK NIO 的内存映射机制，具体使用 MappedByteBuffer（基于
2022-02-03 RocketMQ
RocketMQ消息存储 RocketMQ消息存储
目前的MQ中间件从存储模型来，分为需要持久化和不需要持久化的两种模型，现在大多数的是支持持久化存储的，比如ActiveMQ、RabbitMQ、Kafka、RocketMQ。ZeroMQ却不需要支持持久化存储而业务系统也大多需要MQ有持久存储
2022-02-03 RocketMQ
RocketMQ死信队列 RocketMQ死信队列
RocketMQ的死信队列介绍就没有RabbitMQ那么复杂。在这篇文章会简单的介绍一下RocketMQ死信队列的特点。 死信消息特性 不会再被消费者正常消费 有效期与正常消息相同，均为 3 天，3 天后会被自动删除。故死信消息应在产生的
2022-02-01 RocketMQ
RocketMQ消息保障 RocketMQ消息保障
1. 生产端保障生产端保障需要从以下几个方面来保障 使用可靠的消息发送方式 注意生产端重试 生产禁止自动创建topic 1.1 ⚠消息发送保障1.1.1同步发送发送者向MQ执行发送消息API时，同步等待，直到消息服务器返回发送结果，会在
2022-02-01 RocketMQ
RocketMQ消息投递策略 RocketMQ消息投递策略
​ RocketMQ的消息投递分分为两种：一种是生产者往MQ Broker中投递；另外一种则是MQ broker 往消费者 投递(这种投递的说法是从消息传递的角度阐述的，实际上底层是消费者从MQ broker 中Pull拉取的)。 Rock
2022-02-01 RocketMQ
5 / 71