我找不到专门的官方文档来解释这一主题。你能帮我理解以下问题吗。
./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]在这一背景下，元数据的价值是什么？
如何经常更新此值？
没有元数据-如果没有元数据意味着此值无效？
1条答案
按热度按时间vi4fp9gy1#
自
kafka 0.9，不是zookeeper它存储关于每个groupid在一个主题上按分区消耗的偏移量的信息。Kafka现在将这些信息存储在一个名为
__consumer_offsets
Metadata描述当前可用的代理及其主机和端口信息，并提供有关哪些代理承载哪些分区的信息。这个
NO_METADATA是这种情况下的违约行为。