【发布时间】:2021-07-28 16:03:19
【问题描述】:
我可以在/var/log/kafka.log位置找到以下错误
[2021-07-28 05:15:16,801] INFO [GroupCoordinator 2]:准备重新平衡组 kafka-stream-confluent-grp1-20-entities-distributed 在状态 PreparingRebalance 与老一代 18 (__consumer_offsets-48) (原因:在心跳到期时删除成员 kafka-stream-confluent-grp1-20-entities-distributed-68dabbd3-28b6-433b-bd5b-9b1438946024-StreamThread-4-consumer-1600bf78-e4ca-4ddf-86e9-cd2d4a06dd57)(kafka .coordinator.group.GroupCoordinator)
我们在哪里可以找到消费者级别的心跳日志?还是我们需要启用它们?我假设这样我可以确保在这么长的时间内收到这些消费者线程的心跳。
【问题讨论】:
标签: java apache-kafka log4j apache-kafka-streams