我开始学习Kafka,试图理解当Kafka集群中某个主题的分区超出其限制时会发生什么。我知道一个分区驻留在同一个节点上,但是不同的分区驻留在不同的节点上。如果我在kafka producer中使用自定义分区逻辑,其中某个键总是指向某个分区,那么当该分区变满时会发生什么?具有此密钥的消息是否发送到随机分区?
vsaztqbk1#
分区刚刚被清理,所有的消息都被删除,这样新的消息就可以被发送到同一个分区。“retention”策略由所有“log.retention.*”代理参数处理。
1条答案
按热度按时间vsaztqbk1#
分区刚刚被清理,所有的消息都被删除,这样新的消息就可以被发送到同一个分区。“retention”策略由所有“log.retention.*”代理参数处理。