根据Kafka文件
当offset manager收到offsetcommitrequest时，它会将请求附加到一个名为\uu consumer\u offset的特殊压缩Kafka主题
我们是否可以通过编程直接访问它？使用kafka工具1.0beta2，我可以看到消费者提供的主题和许多分区，其中只有一个分区有数据。无法理解分区是如何在其中创建的，以及为什么只有一个分区有数据。
现在，在本主题中，如何提交特定分区？
根据Kafka文件
当offset manager收到offsetcommitrequest时，它会将请求附加到一个名为\uu consumer\u offset的特殊压缩Kafka主题
我们是否可以通过编程直接访问它？使用kafka工具1.0beta2，我可以看到消费者提供的主题和许多分区，其中只有一个分区有数据。无法理解分区是如何在其中创建的，以及为什么只有一个分区有数据。
现在，在本主题中，如何提交特定分区？
1条答案
按热度按时间zpjtge221#
\uuu consumer\u offset主题的布局和内容是一个kafka实现细节，您不应该尝试直接访问它。而是使用此处描述的consumermetadata、offsetcommit和offsetfetch api请求：https://cwiki.apache.org/confluence/display/kafka/a+guide+to+the+kafka+protocol#aguidetothekafkaprotocol-offsetcommit/fetchapi