提要:当消费者客户端很久不和kafka通信时,即不发送心跳。kafka会启动自平衡,丢弃这个消费者。 目前通过线程组方法已启动多个消费者线程。但现在有个问题,因为是Kafka的线程池组执行消耗数据,可能会存在所有的消费线程组同时执行任务的 情况。当是这种情况下发。会堵塞消费者和kafka确认消息是否消耗。也就是kafka通信,那么这种情况会不会触发kafka消费者自平衡? 1 心跳是什么时候发送,是否poll方法时发送?
poll和提交offset的时候发送。
你的答案