我开始使用 Kafka 并尝试准确理解在 Kafka 集群中某个主题的分区填满超出其限制的情况下会发生什么。我知道分区驻留在同一节点中，但不同的分区驻留在不同的节点中。如果我在 Kafka 生产者中使用自定义分区逻辑，其中某个键总是进入某个分区，那么当该分区变满时会发生什么？具有此密钥的邮件是否已发送到随机分区？
只清理分区并删除所有消息，以便可以将新消息发送到同一分区。 “保留”策略由所有“log.retention.*”代理参数处理。
1 回答
只清理分区并删除所有消息，以便可以将新消息发送到同一分区。 “保留”策略由所有“log.retention.*”代理参数处理。