Yige

消费者提交偏移量 消费者往一个叫做_consumer_offset 的特殊主题发送消息，消息里包含每个分区的偏移量。 如果消费者一直处于运行状态，那么偏移量就没有什么用处。不过，如果消费者发生崩溃或者有新 的消费者加入群组，就会触发再均衡，完成再均衡之后…

一、Kafka 基本概念 Producer: 消息和数据的生产者，向 kafka 的一个 Topic 发布消息的进程 / 代码 / 服务 Consumer: 消息和数据的消费者，订阅数据（topic）并且处理其发布的消息的进程 / 代码 / 服务 Consumer Group:…