从Apache风暴三叉戟记录Kafka分区和偏移量

o4tp2gmn 于 2021-06-06 发布在 Kafka

关注(0)|答案(0)|浏览(159)

使用ApacheStormTrident从kafka消费消息时，kafka分区和相应的偏移量存储在哪里？我能在暴风动物园里找到些东西 ls /transactional/<StreamName>/coordinator/meta . 但我无法理解这些偏移量是什么，它们属于哪个分区？如何在运行trident拓扑时检查消费者延迟？

apache-kafka lag apache-storm trident Offset

来源：https://stackoverflow.com/questions/50483737/logging-kafka-partition-and-offset-from-apache-storm-trident

暂无答案！

目前还没有任何答案，快来回答吧！

我来回答

从Apache风暴三叉戟记录Kafka分区和偏移量

暂无答案！

相关问题

热门标签

最新问答