内容

• [ ] 消费者线程不安全?
• [ ] 消费者只有一个主线程?? 我看到生产者是有主线程和 sender 线程的.

消费者与消费者组:

看到了, 一个消费者组中的消费者对应一个主题下的一个分区, 多出来的消费者分不到 partition, 那就很尴尬了.

消费者客户端请求流程:

1. 消费者配置, 创建消费者
2. 订阅主题
3. poll 消息
4. 提交 offset
5. 关闭资源

代码Demo 整理到项目中.