在设置了Kafka Broker集群并创建了几个主题之后,我们发现Kafka自动创建了以下两个主题:
__consumer_offsets
_schema
这些主题的重要性和用途是什么?
请您参考如下方法:
__consumer_offsets 用于存储有关每个主题的 promise 偏移量的信息:每组使用者的分区(groupID)。
它是紧凑的主题,因此数据将被定期压缩,并且仅提供最新的偏移量信息。
_schema -不是默认的kafka主题(至少在kafka 8,9处)。它是由Confluent添加的。查看更多:Confluent Schema Registry-github.com/confluentinc/schema-registry(感谢@serejja)