1.解壓kafka壓縮包(移動kafka到/usr/local/下,我的喜愛):node
[root@localhost package]# tar -zxvf kafka.tar.gzvim
2.修改配置文件config/server.properties測試
[root@localhost package]# vim /usr/local/kafka/config/server.propertiesspa
####broker_id#### 替換成kafka序號,幾臺機器分別就是1到幾code
####host_name#### 替換成當前機器的hostnameserver
####host_name#### 替換成當前機器的hostnameblog
####Path#### 替換成kafka的安裝目錄進程
zookeeper.connect=####hosts_name#### 替換成zk集羣名稱kafka
參考以下:console
broker.id=1
host.name=node187
advertised.host.name=node187
log.dirs=/home/bigdata/kafka/kafka-logs
zookeeper.connect=node187:2181,node188:2181,node189:2181
3.啓動kafka(先要確保zookeeper
已啓動,而後在Kafka目錄執行)
nohup bin/kafka-server-start.sh config/server.properties
若是無報錯則說明啓動成功。nohup &
是實如今後臺啓動。
4.查看進程
jps
5.簡單測試
打開2個終端,分別在Kafka目錄執行如下命令
啓動producer
bin/kafka-console-producer.sh --broker-list 192.168.148.128:9092 --topic test
啓動consumer
bin/kafka-console-consumer.sh --zookeeper 192.168.148.128:2181 --topic test --from-beginning