本文主要是介绍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功能
这篇关于Kafka篇之清理或创建topic的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
