删除kafka指定topic下数据

设置指定topic下数据过期时间：./bin/kafka-configs.sh --zookeeper localhost:2181 --entity-type topics --entity-name MARC_INSTANCE_SYNC --alter --add-config retention.ms=1000Warning: --zookeeper is deprecated and w

斜月三

2421人浏览 · 2021-12-09 16:56:37

斜月三 · 2021-12-09 16:56:37 发布

设置指定topic下数据过期时间：

./bin/kafka-configs.sh --zookeeper localhost:2181 --entity-type topics --entity-name MARC_INSTANCE_SYNC --alter --add-config retention.ms=1000
Warning: --zookeeper is deprecated and will be removed in a future version of Kafka.
Use --bootstrap-server instead to specify a broker to connect to.
Completed updating config for entity: topic 'MARC_INSTANCE_SYNC'.

确认设置是否成功：
./bin/kafka-configs.sh --zookeeper localhost:2181 --describe --entity-type topics --entity-name MARC_INSTANCE_SYNC
Warning: --zookeeper is deprecated and will be removed in a future version of Kafka.
Use --bootstrap-server instead to specify a broker to connect to.
Configs for topic 'MARC_INSTANCE_SYNC' are retention.ms=1000

删除上面设置：
./bin/kafka-configs.sh --zookeeper localhost:2181 --entity-type topics --entity-name MARC_INSTANCE_SYNC --alter --delete-config retention.ms
Warning: --zookeeper is deprecated and will be removed in a future version of Kafka.
Use --bootstrap-server instead to specify a broker to connect to.
Completed updating config for entity: topic 'MARC_INSTANCE_SYNC'.

确认删除是否成功:
./bin/kafka-configs.sh --zookeeper localhost:2181 --describe --entity-type topics --entity-name MARC_INSTANCE_SYNC Warning: --zookeeper is deprecated and will be removed in a future version of Kafka.
Use --bootstrap-server instead to specify a broker to connect to.
Configs for topic 'MARC_INSTANCE_SYNC' are