如何解决如何获取 kafka 偏移量以及创建这些偏移量/记录的时间
我基本上是在尝试使用 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 举报，一经查实，本站将立刻删除。
