为什么kafka connect内部主题connect-offsets有50个分区，connect-status有10个分区？

Question

根据阅读kafka connect文档:

https://docs . confluent . io/5 . 3 . 3/connect/user guide . html #分布式模式

config . storage . topic =连接-配置

bin/kafka-topics --create --zookeeper localhost：2181 --topic connect-configs --replication-factor 3 --partitions 1 --config cleanup.policy=compact

offset.storage.topic=connect-offsets

bin/kafka-主题-创建-动物园管理员localhost:2181-主题连接-偏移-复制因子3-分区50-配置cleanup.policy=紧凑

status.storage.topic=连接状态

bin/kafka topics--create--zookeeper localhost:2181--topic connect status--replication factor 3--partitions 10--config cleanup.policy=compact

我理解为什么连接配置只有一个分区，它必须是唯一的分区，好吧。但是我不明白，也无法获得有关为什么连接偏移量应该有 50 个分区和连接状态 10 的信息

Answer 1

这只是一个猜测，但分区将负载分散在一个主题上。

我不知道这些主题中每个主题的确切功能是什么，但如果我不得不猜测，我会说配置可能不会连续访问，因为看起来它存储了配置。状态很可能是定期更新的，但偏移量不是那么频繁。偏移量始终由源连接器更新。

因此，文档可能会根据预期负载创建具有这些分区数的主题，并明确设置它们在创建主题时不依赖默认分区数。

例如，这里说

< code > offset . storage . partitions

Connect创建用于存储连接器偏移的主题时使用的分区数。支持大型Kafka Connect集群需要较大的值（例如，25或50，就像Kafka内置的__consumer_offsets主题）。

和

status.storage.partitions

Connect创建用于存储连接器和任务状态更新的主题时使用的分区数。

默认值：5

默认为少数