__consumer_offsets :概念理解

Question

我找不到专门的官方文档来解释这个__consumer_offsets主题。你能帮我理解以下问题吗？

./kafka-simple-consumer-shell.sh --topic __consumer_offsets \
--partition 49 \
--broker-list localhost:9092 \
--formatter "kafka.server.OffsetManager\$OffsetsMessageFormatter"

testGroup,testTopic-development,0]::OffsetAndMetadata[11,NO_METADATA,1478243992053]
[testGroup,testTopic-development,0]::OffsetAndMetadata[12,NO_METADATA,1478243992086]
[testGroup,testTopic-development,0]::OffsetAndMetadata[13,NO_METADATA,1478243992096]
[testGroup,testTopic-development,0]::OffsetAndMetadata[14,NO_METADATA,1478243992110]

在这个特殊主题的上下文中元数据值是什么?这个值如何得到frequently?

• NO_METADATA ?如果没有元数据，这个值是无效的?

。

Answer 1

自kafka 0.9以来，不再是zookeeper存储关于每个主题按分区使用的偏移量的信息。

卡夫卡现在将这些信息存储在一个名为__consumer_offsets的主题上

Metadata描述当前可用的代理、它们的主机和端口信息，并提供有关哪个代理主机的信息。

在这种情况下，NO_METADATA是默认行为。