您的位置:首页 > 健康 > 美食 > Kafka篇之清理或创建topic

Kafka篇之清理或创建topic

2024/10/6 14:29:07 来源:https://blog.csdn.net/xu710263124/article/details/141399425  浏览:    关键词:Kafka篇之清理或创建topic

1. kafka清理topic主题

清理topic步骤:
step1:

./kafka-topics.sh --bootstrap-server 10.143.167.41:9092,10.143.167.42:9092,10.143.167.43:9092 --delete --topic reflow_data_topic

请注意,如果 Kafka 的配置中没有设置 delete.topic.enable 为 true,那么此操作不会产生任何影响。
要确保删除主题生效,请遵循以下步骤:
step2:
编辑配置文件server.properties

vim server.properties
delete.topic.enable=true

step3:
重新启动 Kafka 服务器。

systemctl restart kafka

查询kafka所有的topic信息

kafka-topics.sh --bootstrap-server localhost:9092 --list

例如:

kafka-topics.sh --bootstrap-server 10.127.192.16:9092,10.127.192.160:9092,10.127.192.175:9092 --list

2. kafka创建topic

以下为手动创建kafka topic

kafka-topics.sh --bootstrap-server 10.127.192.16:9092,10.127.192.160:9092,10.127.192.175:9092 --create --topic aicore_alg_status

kafka自动创建topic
可以进行如下修改

vim server.properties
auto.create_topics.enable=true

重启kafka

systemctl restart kafka

自此,kafka便可以实现自动创建topic功能

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com