自动删除闲置主题
Kafka允许设置一个主题在一段时间内没有被消费者消费时自动删除。这需要在服务器配置中启用删除策略,并设置一个删除时间间隔。
以下是在Kafka服务器中设置自动删除的示例代码:
bin/kafka-topics.sh --zookeeper localhost:2181 —alter --topic my_topic --config retention.ms=604800000
bin/kafka-topics.sh --zookeeper localhost:2181 —alter --topic my_topic --config retention.bytes=1073741824
bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic my_topic --config delete.retention.ms=604800000
这个示例代码将主题“my_topic”的保留时间设置为7天,并将自动删除间隔设置为7天。这意味着,如果主题在7天内没有收到任何新消息,则它将被自动删除。