情况：
班级 KafkaConsumer 有一些不错的方法，比如： partitionFor , begginingOffsets 以及 endOffsets 也 commited 以及 position .
所有这些方法都很有用，例如在评估主题中的负载情况时。
使用流时- KStream ，如何获取偏移量状态等元数据信息？
如何在java代码流状态下签入运行时？
情况：
班级 KafkaConsumer 有一些不错的方法，比如： partitionFor , begginingOffsets 以及 endOffsets 也 commited 以及 position .
所有这些方法都很有用，例如在评估主题中的负载情况时。
使用流时- KStream ，如何获取偏移量状态等元数据信息？
如何在java代码流状态下签入运行时？
1条答案
按热度按时间p3rjfoxz1#
此时，使用dsl访问您描述的属性（不管怎样，这些属性的子集）的唯一方法是使用
#transform()和或#process(). 这些基本上是处理器api方法，因此您可以访问ProcessorContext，它允许您访问主题、分区、偏移量和时间戳。否则您无法使用dsl访问这些属性。在Kafka流中根本无法访问partitionfor、begginingoffsets、endoffsets、committed或position。这些都是完全隐藏的。