gpt4 book ai didi

java - 如何访问和提交卡夫卡__consumer_offsets主题的偏移量?

转载 作者:塔克拉玛干 更新时间:2023-11-02 08:08:32 25 4
gpt4 key购买 nike

根据卡夫卡文档

When the offset manager receives an OffsetCommitRequest, it appends the request to a special compacted Kafka topic named __consumer_offsets

我们是否可以直接以编程方式访问它?使用 Kafka Tool 1.0 Beta 2,我可以看到 __consumer_offets 主题和其中的许多分区,只有一个分区有数据。无法理解它是如何在其中创建分区以及为什么只有一个分区有数据。

现在还有我如何提交这个主题中的特定分区?

最佳答案

__consumer_offsets 主题的布局和内容是 Kafka 实现细节,您不应尝试直接访问它。而是使用此处描述的 ConsumerMetadata、OffsetCommit 和 OffsetFetch API 请求:https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-OffsetCommit/FetchAPI

关于java - 如何访问和提交卡夫卡__consumer_offsets主题的偏移量?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/32246647/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com