【问题标题】:Where are Kafka heartbeat related logs in Confluent Platform?Confluent Platform 中的 Kafka 心跳相关日志在哪里?
【发布时间】: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


    【解决方案1】:

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

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

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

    要显示发送的心跳,您需要启用调试日志记录,

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

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

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

    【讨论】:

      猜你喜欢
      • 2019-04-17
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2021-12-22
      • 1970-01-01
      • 2018-06-12
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多