情况:
班级 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。这些都是完全隐藏的。