问题描述
我基本上是在尝试使用 bin\kafka-run-class kafka.tools.GetoffsetShell 查询偏移信息
我提供经纪人列表和主题信息作为参数。
参考 - GetOffsetShell Utility
但我面临 - Exception in thread "main" java.lang.OutOfMemoryError: Java heap space
这里有两篇 SOF 帖子涉及同一主题——
Retrieve Timestamp based data from Kafka 和
kafka-run-class throwing java.lang.OutOfMemoryError error。
所以这个问题与kafka-run-class kafka.tools.GetoffsetShell无关。所以我想检查一下还有哪些其他工具可用于查询 kafka 偏移信息 - 诸如偏移和创建偏移的时间等信息。
kafka-consumer-groups.sh 对我的用例没有帮助，因为它不提供/允许获取创建记录/偏移量的时间戳。
注意：我想我们正在使用融合的 kafka - 5.3.x 和 SSL/JAAS auth mechnasim
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）