Confluent Platform 中的 Kafka 心跳相关日志在哪里？

Question

我可以在 /var/log/kafka.log

位置找到以下错误

[2021-07-28 05:15:16,801] INFO [GroupCoordinator 2]: Preparing to rebalance group kafka-stream-confluent-grp1-20-entities-distributed in state PreparingRebalance with old generation 18 (__consumer_offsets-48) (reason: removing member kafka-stream-confluent-grp1-20-entities-distributed-68dabbd3-28b6-433b-bd5b-9b1438946024-StreamThread-4-consumer-1600bf78-e4ca-4ddf-86e9-cd2d4a06dd57 on heartbeat expiration) (kafka.coordinator.group.GroupCoordinator)

我们在哪里可以找到消费者级别的心跳日志？还是我们需要启用它们？我假设这样我就可以确保在这么长的时间内收到这些消费者线程的心跳。

Answer 1

这里有一些关于心跳的很好的参考资料...

https://chrzaszcz.dev/2019/06/kafka-heartbeat-thread/

如果发生心跳错误，您会在日志中看到 ERROR，

要显示发送的心跳，您需要启用 DEBUG 日志记录，

 log.debug("Sending Heartbeat request with generation {} and member id {} to coordinator {}",

对于接收到的心跳信息，您需要启用 TRACE 日志记录

  log.trace("{}: got heartbeat status {}", node.name(), agentStatus);

Confluent Platform 中的 Kafka 心跳相关日志在哪里？

Where are Kafka heartbeat related logs in Confluent Platform?

java

apache-kafka

log4j

apache-kafka-streams