server.properties核心配置詳解：
PropertyDefaultDescriptionbroker.id0每個broker都可以用一個唯一的非負整數(shù)id進行標識；這個id可以作為broker的“名字”，你可以選擇任意你喜歡的數(shù)字作為id，只要id是唯一的即可 。log.dirs/tmp/kafka-logskafka存放數(shù)據(jù)的路徑 。這個路徑并不是唯一的，可以是多個，路徑之間只需要使用逗號分隔即可；每當創(chuàng)建新partition時，都會選擇在包含最少partitions的路徑下進行 。listenersPLAINTEXT://192.168.65.60:9092server接受客戶端連接的端口，ip配置kafka本機ip即可zookeeper.connectlocalhost:2181zooKeeper連接字符串的格式為：hostname:port，此處hostname和port分別是ZooKeeper集群中某個節(jié)點的host和port；zookeeper如果是集群，連接方式為 hostname1:port1, hostname2:port2, hostname3:port3log.retention.hours168每個日志文件刪除之前保存的時間 。默認數(shù)據(jù)保存時間對所有topic都一樣 。num.partitions1創(chuàng)建topic的默認分區(qū)數(shù)default.replication.factor1自動創(chuàng)建topic的默認副本數(shù)量，建議設置為大于等于2min.insync.replicas1當producer設置acks為-1時，min.insync.replicas指定replicas的最小數(shù)目（必須確認每一個repica的寫數(shù)據(jù)都是成功的），如果這個數(shù)目沒有達到，producer發(fā)送消息會產(chǎn)生異常delete.topic.enablefalse是否允許刪除主題第四步：創(chuàng)建主題現(xiàn)在我們來創(chuàng)建一個名字為“test”的Topic，這個topic只有一個partition，并且備份因子也設置為1：
bin/kafka-topics.sh –create –zookeeper 192.168.65.60:2181 –replication-factor 1 –partitions 1 –topic test
現(xiàn)在我們可以通過以下命令來查看kafka中目前存在的topic
bin/kafka-topics.sh –list –zookeeper 192.168.65.60:2181
除了我們通過手工的方式創(chuàng)建Topic，當producer發(fā)布一個消息到某個指定的Topic，這個Topic如果不存在，就自動創(chuàng)建 。
刪除主題
bin/kafka-topics.sh –delete –topic test –zookeeper 192.168.65.60:2181
第五步：發(fā)送消息kafka自帶了一個producer命令客戶端，可以從本地文件中讀取內(nèi)容，或者我們也可以以命令行中直接輸入內(nèi)容，并將這些內(nèi)容以消息的形式發(fā)送到kafka集群中 。在默認情況下，每一個行會被當做成一個獨立的消息 。
首先我們要運行發(fā)布消息的腳本，然后在命令中輸入要發(fā)送的消息的內(nèi)容：
bin/kafka-console-producer.sh –broker-list 192.168.65.60:9092 –topic test >this is a msg >this is a another msg
第六步：消費消息對于consumer，kafka同樣也攜帶了一個命令行客戶端，會將獲取到內(nèi)容在命令中進行輸出，默認是消費最新的消息：
bin/kafka-console-consumer.sh –bootstrap-server 192.168.65.60:9092 –topic test
如果想要消費之前的消息可以通過–from-beginning參數(shù)指定，如下命令：
bin/kafka-console-consumer.sh –bootstrap-server 192.168.65.60:9092 –from-beginning –topic test
如果你是通過不同的終端窗口來運行以上的命令，你將會看到在producer終端輸入的內(nèi)容，很快就會在consumer的終端窗口上顯示出來 。
以上所有的命令都有一些附加的選項；當我們不攜帶任何參數(shù)運行命令的時候，將會顯示出這個命令的詳細用法 。
消費多主題
bin/kafka-console-consumer.sh –bootstrap-server 192.168.65.60:9092 –whitelist “test|test-2”
單播消費
一條消息只能被某一個消費者消費的模式，類似queue模式，只需讓所有消費者在同一個消費組里即可
分別在兩個客戶端執(zhí)行如下消費命令，然后往主題里發(fā)送消息，結(jié)果只有一個客戶端能收到消息
bin/kafka-console-consumer.sh –bootstrap-server 192.168.65.60:9092 –consumer-property group.id=testGroup –topic test

以上關(guān)于本文的內(nèi)容，僅作參考！溫馨提示：如遇健康、疾病相關(guān)的問題，請您及時就醫(yī)或請專業(yè)人士給予相關(guān)指導!

• 一般的玉手鐲賣多少錢:翡翠項鏈編織繩，好的項鏈要配獨一無二的繩子
• 一般的玉手鐲賣多少錢:翡翠項鏈鑒定機構(gòu)，專業(yè)的就是讓人信賴
• 2022年天貓年貨節(jié)紅包入口在哪里 天貓年貨節(jié)紅包口令怎么設置的
• 2022大連泉水疫情源頭在哪 大連疫情活動軌跡是怎樣的
• 蘇打水是碳酸飲料嗎
• 文玩核桃怎么清洗
• 坐飛機的流程步驟有哪些?
• 原唱者王琪攜手許歌淳主演院線電影 可可托海的牧羊人原唱
• 鏡子是用什么材料做的
• 筋膜槍怎么使用