kafka環境搭建

1.下載kafka壓縮包kafka_2.9.1-0.8.2.1.tgz 用tar -zxvf 命令解壓到建立kafka的目錄下面

2.建立kafkalog配置文件kafkaLog

3.修改kafka配置文件 server.properties

   主要說明下須要修改的基本參數，其餘能夠參照apache kafka官方文檔

   我本身是三臺虛擬服務器：

   broker.id=0 從0開始 每一臺及其取名不同，你能夠設置爲0，1，2····

   host.name=ip 這個註解須要放開並將後面的localhost替換成你的ip地址

   log.dirs=/home/test/kafka/kafkaLogs 這個指向剛纔建立的日誌目錄

   num.partitions=2 默認是1，你也能夠不修改

   message.max.byte=573741824設置信息最大致諒爲5M（後加）
   default.replication.factor=2
   replica.fetch.max.bytes=573741824

   zookeeper.connect=IP:12181,IP:12181 設置的zookeeper集羣及其的IP以及端口

4.啓動與測試kafka服務

  建立一個kafka的topic命令 ./kafka-topics.sh --create --zookeeper Ip:12181 --replication-factor 1 --partitions 2 --topic test

  查看kakfa中topic列表./kafka-topics.sh --list --zookeeper IP:12181

  

  啓動生產者./kafka-console-producer.sh --broker-list IP:9092 --topic test

  啓動消費端./kafka-console-consumer.sh --zookeeper 121.40.194.104:12181 --topic talk --from-beginning

   以上基本是kafka的部署內容。