kafka多线程并发时消费者自平衡问题

答人 发表于: 2018-08-04   最后更新时间: 2018-08-04 23:16:40   5,793 游览

提要:当消费者客户端很久不和kafka通信时,即不发送心跳。kafka会启动自平衡,丢弃这个消费者。

目前通过线程组方法已启动多个消费者线程。但现在有个问题,因为是Kafka的线程池组执行消耗数据,可能会存在所有的消费线程组同时执行任务的 情况。当是这种情况下发。会堵塞消费者和kafka确认消息是否消耗。也就是kafka通信,那么这种情况会不会触发kafka消费者自平衡?

1 心跳是什么时候发送,是否poll方法时发送?

发表于 2018-08-04
添加评论

poll和提交offset的时候发送。

你的答案

查看kafka相关的其他问题或提一个您自己的问题