一、創(chuàng)建topic
裝有kafka的系統(tǒng)命令行界面執(zhí)行以下命令創(chuàng)建名為test的topic
kafka-topics --create --zookeeper localhost:2180 --replication-factor 2 --partitions 3 --topic test說明：
--create? ? ? ? ? ? ? ? ? ? ? 表示要對kafka執(zhí)行創(chuàng)建的操作?
--zookeeper? ? ? ?????????指定自己的zookeeper連接地址，這里是localhost:2180
--replication-factor? ? ? 指定保存數據的副本數，這里是2，可以根據自己需求指定
--partitions? ? ? ? ? ? ? ? ? 指定保存數據的分區(qū)數，這里是3，可以根據自己需求指定
--topic? ? ? ? ? ? ? ? ? ? ? ? ?指定要創(chuàng)建的topic（kafka里面的表）名字
二、kafka命令行消費者
在kafka節(jié)點執(zhí)行kafka-console-consumer命令行工具
kafka-console-consumer --bootstrap-server test1:9192,test2:9192,test3:9192 --topic test說明：
--bootstrap-server? ? ? ?指定kafka的塊地址，這里是?test1:9192,test2:9192,test3:9192 需要替換自己的kafka塊連接地址。（ps：只要網絡可以通信，使用該命令行消費工具也可以指定其他kafka集群的topic進行消費）
--topic? ? ? ? ? ? ? ? ? ? ? ? ?指定需要進行消費的kafka topic
其他參數：
--from-beginning? ? ? ? ?添加該參數表示從topic的最開始位置進行消費，不指定則默認從topic的最新位置進行消費
三、kafka命令行生產者
kafka-console-producer --broker-list test1:9092,test2:9092,test3:9092 --topic test說明：
--broker-list? ? ? ? ? ? ? ? ?指定kafka的塊地址，這里是?test1:9192,test2:9192,test3:9192 需要替換自己的kafka塊連接地址。（ps：只要網絡可以通信，使用該命令行生產者工具也可以指定其他kafka集群的topic進行生產數據）
--topic? ? ? ? ? ? ? ? ? ? ? ? ?指定生產數據的kafka topic
四、刪除topic
如果要刪除topic和數據塊，需要設置kafka的配置文件server.properites
添加delete.topic.enable=true
然后重啟kafka。如果只是邏輯刪除topic，并不刪除數據塊，則可以不配置。
kafka-topics --zookeeper localhost:2181 --topic test --delete說明：
--delete? ? ? ? ? ? ? ? ?????????表示要對kafka執(zhí)行刪除的操作?
--zookeeper? ? ? ? ? ? ? ? ? ?指定自己的zookeeper連接地址，這里是localhost:2180
--topic? ? ? ? ? ? ? ? ? ? ? ? ? ??指定要刪除的topic名字
五、kafka單個topic增加配置
這里以單獨把topic test的數據保存天數設置為永久為例。
kafka-configs --zookeeper localhost:2181 --alter --add-config 'retention.ms=-1' --entity-name test --entity-type topics說明：
--zookeeper? ? ? ? ? ? ? ? ? ?指定自己的zookeeper連接地址，這里是localhost:2180
--alter? ? ? ? ? ? ? ? ? ? ? ? ? ? ?表示要進行配置修改命令
--add-config? ? ? ? ? ? ? ? ? ? 要添加的鍵值對配置。方括號可用于對包含逗號的值進行分組：'k1 = v1, k2 = [v1, v2, v3], k3 = v3'
--entity-name? ? ? ? ? ? ? ? ?要操作實體的名稱，topic名、客戶端id、userID、brokerID文章來源：http://www.zghlxwxcb.cn/news/detail-410925.html
--entity-type? ? ? ? ? ? ? ? ? ?實體配置的類型可以是topics、clients、users、brokers文章來源地址http://www.zghlxwxcb.cn/news/detail-410925.html
到了這里，關于kafka創(chuàng)建topic、添加配置等相關操作的文章就介紹完了。如果您還想了解更多內容，請在右上角搜索TOY模板網以前的文章或繼續(xù)瀏覽下面的相關文章，希望大家以后多多支持TOY模板網！
