kafka 消费数据

消费模型

• pull / push

消费数据肯存在的问题

• 消息重复消费
• 消息丢失
• 解决方法：使用手动 commit 和 自动 commit。