Kafka如何处理分区溢出？

Question

我开始使用 Kafka，并试图了解当 Kafka 集群中的主题分区填满超出其限制时会发生什么情况。我知道一个分区驻留在同一个节点中，但不同的分区驻留在不同的节点中。如果我在 Kafka 生产者中使用自定义分区逻辑，其中某个键总是转到某个分区，那么当该分区变满时会发生什么？是否将具有此密钥的消息发送到随机分区？

Answer 1

刚刚清理分区，删除所有消息，以便将新消息发送到同一分区。 "retention" 策略由所有 "log.retention.*" 代理参数处理。