在 Kafka 中使用 KStream 时如何获取偏移状态和其他元数据信息？
How to get offset status and other metadata information when working with KStream in Kafka?
情况：
class KafkaConsumer 有一些不错的方法，例如：partitionFor、begginingOffsets 和 endOffsets 还有 commited 和 position.
所有这些方法在评估时都很有帮助，例如主题中的负载情况。
使用流时 - KStream，如何获取偏移状态和其他元数据信息？
如何在 Java 码流状态下查看运行时？
目前，使用 DSL 访问您描述的属性（无论如何，这些属性的子集）的唯一方法是使用 #transform() 和/或 #process()。这些基本上是 Processor API 方法，因此您可以访问 ProcessorContext，这使您可以访问主题、分区、偏移量和时间戳。否则您无法使用 DSL 访问这些属性。
根本无法访问 Kafka Streams 中的 partitionFor、begginingOffsets、endOffsets、committed 或位置。这些都是完全隐藏的。
情况：
class KafkaConsumer 有一些不错的方法，例如：partitionFor、begginingOffsets 和 endOffsets 还有 commited 和 position.
所有这些方法在评估时都很有帮助，例如主题中的负载情况。
使用流时 - KStream，如何获取偏移状态和其他元数据信息？
如何在 Java 码流状态下查看运行时？
目前，使用 DSL 访问您描述的属性（无论如何，这些属性的子集）的唯一方法是使用 #transform() 和/或 #process()。这些基本上是 Processor API 方法，因此您可以访问 ProcessorContext，这使您可以访问主题、分区、偏移量和时间戳。否则您无法使用 DSL 访问这些属性。
根本无法访问 Kafka Streams 中的 partitionFor、begginingOffsets、endOffsets、committed 或位置。这些都是完全隐藏的。