下麵是在消費者終端中顯示的消息的語法
Bin /kafka-console-consumer.sh——zookeeper localhost:4536 -topic topic-name
——從頭
除非在config/consumer中另有指定，否則默認的消費者屬性將適用。零件的文件。
使用多個Kafka配置創建一個主題
它的語法是-
Bin /kafka-topic .sh——create——zookeeper localhost:4381——replication-factor
-partitions 1——topic topic-name
這裏，複製因子是根據正在運行的代理的數量選擇的。讓我們看一個複製因子為2 -的結果語法示例
Bin /kafka-topic .sh——create——zookeeper localhost:2181——replication-factor
-分區1——topic Multibrokerapplication
輸出將是-
創建主題“Multibrokerapplication”
您還可以使用' Describe '命令來驗證哪個代理正在偵聽特定的主題。
Bin /kafka-topic .sh——describe——zookeeper localhost:2671
——主題Multibrokerappli-cation
輸出結果將顯示為-
Bin /kafka-topic .sh——describe——zookeeper localhost:2671
——主題Multibrokerappli-cation
主題:Multibrokerapplication PartitionCount: 1
ReplicationFactor: 2款:
主題:Multibrokerapplication分區:0 Leader:0
副本:0 2 1 Isr: 0、2、1
該輸出的第一行總結了分區的數量，包括主題名稱、分區計數和複製因子。第二行指示leader是代理id為0的第一個代理，所有代理都複製主題“lsr”的子集。