如何覆盖 Kafka 代理的存储时间配置？

Question

我正在阅读 Kafka 文档，它说它可以在可配置的时间内存储主题，

我有一些问题

• 如果代理 运行 存储空间不足怎么办？
• 有什么方法可以建议经纪人丢弃内容

Answer 1

您可以选择根据使用 属性 log.retention.bytes 保留的字节额外配置保留时间。

请参阅 broker configuration

下 log.retention.{ms,minutes,hours} 和 log.retention.bytes 的文档