kafa單機版環境搭建

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序號,幾臺機器分別就是1code

  ####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

相關文章
相關標籤/搜索