在 Kafka 中使用 KStream 时如何获取偏移量状态和其他元数据信息?

Question

情况：

类KafkaConsumer有一些不错的方法，例如：partitionFor，begginingOffsets和endOffsets也commited和position。

在评估例如主题中的负载情况时，所有这些方法都是有帮助的。

使用流时 -KStream，如何获取偏移状态和其他元数据信息？

如何在 Java 代码流状态中签入运行时？

Answer 1

目前，使用 DSL 访问您描述的属性(无论如何，这些属性的子集)的唯一方法是使用#transform()和 或#process()。这些基本上是处理器 API 方法，因此您可以访问ProcessorContext，这使您可以访问主题、分区、偏移量和时间戳。否则，无法使用 DSL 访问这些属性。

根本无法访问 partitionFor、begginingOffsets、endOffsets、commit 或 Kafka Streams 中的位置。这些是完全隐藏的。