kafka 配置及常用命令
1. 主要配置 config/server.properties
（1）? broker.id=0? # 集群中，每個(gè) kafka 實(shí)例的值都不一樣
（2） log.dirs=/tmp/kafka-logs? #日志文件的位置
（3） zookeeper.connect=bigdata3:2181,bigdata4:2181,bigdata5:2181? # zookeeper 集群的配置
如果不使用集群，則可以用不配置 zookeeper.connect 這一項(xiàng)，此時(shí)需要先運(yùn)行下面的命令，啟動(dòng)一個(gè)本地的 zookeeper：
bin/zookeeper-server-start.sh config/zookeeper.properties
2. 啟動(dòng) kafka ： bin/kafka-server-start.sh config/server.properties
3. 創(chuàng)建一個(gè) topic：? bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
? ? 此命令為 test?這個(gè) topic?創(chuàng)建了一個(gè)分區(qū)，副本數(shù)為 1，這種情況下，所有 topic?的數(shù)據(jù)都會(huì)存在一個(gè)分區(qū)上，且只有一份。在?kafka?集群模式下，應(yīng)該增加 partitions?和?replication-factor?的值。
? ? zookeeper?為集群模式時(shí)， --zookeeper 的值應(yīng)該是上面 1 中配置的值，如果只寫一個(gè)?zookeeper?的地址，只要那個(gè)?zookeeper?沒(méi)有死掉，仍然是可以正確運(yùn)行的。下面命令中的此值做同樣處理。
4. 查看有哪些 topic：? bin/kafka-topics.sh --list --zookeeper localhost:2181
5. 啟動(dòng)一個(gè)生產(chǎn)者，可以往kafka 中發(fā)送消息：? bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
6. 啟動(dòng)一個(gè)消費(fèi)者，消費(fèi)kafka 中的消息：? bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
7. 查看哪個(gè)topic 的詳細(xì)信息： bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic my-replicated-topic
8.?kafka?集群。只要在另外一臺(tái)電腦上，把?config/server.properties 中的 broker.id?配置成不同的值，然后啟動(dòng)?kafka?就可以了。
?
轉(zhuǎn)載于:https://www.cnblogs.com/langfanyun/p/10238766.html
總結(jié)
以上是生活随笔為你收集整理的kafka 配置及常用命令的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
