有没有办法删除队列消息而不删除Kafka主题? 我想在激活使用者时删除队列消息.
我知道有几种方式:
重置保留时间
$ ./bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic MyTopic --config retention.ms=1000
删除kafka文件
$ rm -rf /data/kafka-logs/<topic/Partition_name>
apache-kafka
apache-kafka ×1