问题描述
我是学习 Kafka 的初学者,正在学习主题和制作人。根据我的理解
-
我的理解是否正确,对于给定的主题,假设有 5 个分区,那么所有 5 个分区都将位于 5 个不同的代理上。如果还有另一个主题有 5 个分区,那么所有 5 个分区都将在 5 个代理上。对于这种配置,5 个代理中的每一个都有两个分区,每个分区都有一个主题。我说得对吗?
-
另一点当生产者发布消息而消费者正在消费时,生产者将配置一个
brokers
列表并将消息发布到topic
和brokers
的列表。该消息将始终写入领导分区。即代理上的分区之一。然后该消息将被复制到其他代理上的所有其他分区。在这种情况下,如果生产者在生产者配置中只配置了一个代理,那么在这种情况下消息是否也被发布到领导分区,即使代理配置与该主题的领导分区不同,例如:主题名称 - 在 5 个代理上具有 5 个分区的事件。 broker-2 包含领导分区,但生产者仅配置了 broker-1。 -
我还读到生产者也可以在发布消息时指定分区名称。如果是这种情况,那么生产者也会将消息发布到领导分区,如果生产者将消息发布到自定义分区,并且包含自定义分区的代理宕机,那么该消息将不会是矛盾的吗?发布。同样在分布式系统的情况下,确定特定分区不是最佳实践。我在这里遗漏了什么吗?
-
消费者也是从lead分区读取还是消费者组将不同的消费者分配到不同的分区?
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)