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