java - 不要坚持主题卡夫卡

Question

我有一个 Kafka 用例，其中我不需要服务器上运行的某些主题的日志，某些主题发送很多消息，而其他主题发送的消息不多。

目前我看到的唯一“解决办法”是设置相当宽松的保留政策。

事情是，我想保留服务器上其他一些主题的日志和持久信息，这对我来说可能更重要。

我有什么选择？

理想情况下，我想按主题丢弃日志和存储的消息。

Answer 1

您可以设置每个主题的保留策略，是的。

这是一个使用kafka-topics的示例:

kafka-topics.sh --zookeeper localhost:2181 \
                --alter \
                --topic MyTopic \
                --config retention.ms=1000