相关疑难解决方法(0)

我需要找到一种方法来向卡夫卡询问一系列主题.我知道我可以使用目录中kafka-topics.sh包含的脚本来做到这一点bin\.有了这个列表,我需要每个主题的所有消费者.我找不到该目录中的脚本,也没有在kafka-consumer-api库中找到允许我这样做的类.

这背后的原因是我需要弄清楚主题偏移量与消费者偏移量之间的差异.

有没有办法实现这个目标？或者我是否需要在每个消费者中实现此功能？