3

由于我的基于KStream的应用程序不遵循传统的 Kafka 消费者路线，我应该如何跟踪消费者滞后？通常我会使用ConsumerOffsetChecker （或类似的东西），但它需要一个消费者组名称。

我应该改用什么？

（我想对此进行跟踪，以便判断是否/何时推出新消费者）

4

1 回答 1

3

Kafka StreamsKafkaConsumer在内部利用，并使用应用程序 ID 作为消费者组 ID。因此，您可以像监控任何其他消费者一样监控延迟。

请参阅http://docs.confluent.io/current/streams/developer-guide.html#required-configuration-parameters

应用程序ID（application.id）：每个流处理应用程序必须有一个唯一的ID。[...]

此 id 用于以下位置，以将应用程序使用的资源与其他资源隔离：

  • 作为默认的 Kafka 消费者和生产者 client.id 前缀
  • 作为 Kafka 消费者 group.id 进行协调
  • 作为状态目录中子目录的名称（参见 state.dir）
  • 作为内部 Kafka 主题名称的前缀
于 2016-09-03T21:12:54.943 回答