消费发送 生产者向消息队列里写入消息，不同的业务场景需要生产者采用不同的写入策略。比如同步发送、 异 […]
RocketMQ是阿里巴巴中间件团队自研的一款高性能、高吞吐量、低延迟、高可用、高可靠（具备 金融级 […]
集群应用场景 消息传递 Kafka可以很好地替代传统邮件代理。消息代理的使用有多种原因（将处理与数据 […]
延时队列 两个follower副本都已经拉取到了leader副本的最新位置，此时又向leader副本 […]
事务 事务场景 如producer发的多条消息组成一个事务这些消息需要对consumer同时可见或者 […]
日志存储概述 Kafka 消息是以主题为单位进行归类，各个主题之间是彼此独立的，互不影响。 每个主题 […]
副本机制 Kafka在一定数量的服务器上对主题分区进行复制。 当集群中的一个broker宕机后系统可 […]
管理 使用kafka-topics.sh脚本： 主题中可以使用的参数定义： 创建主题 查看主题 修改 […]
概念入门 消费者、消费组 消费者从订阅的主题消费消息，消费消息的偏移量保存在Kafka的名字是 __ […]
消息发送 数据生产流程解析 Producer创建时，会创建一个Sender线程并设置为守护线程。 生 […]
