1. 程式人生 > >kafka(1) ====》 安裝kafka

kafka(1) ====》 安裝kafka

kafka的安裝依賴於java,zookeeper:

但是這裡對於java、zookeeper的安裝就不做過多的描述,網上安裝教程有很多。

這裡假設你已經安裝好java和zookeeper了

首先下載一個kafka的安裝包,地址:http://kafka.apache.org/downloads

安裝步驟很簡單

1) tar -zxf kafka_2.11-0.9.0.1.tgz

2) mv kafka_2.11-0.9.0.1 /usr/local/kafka  (更改安裝目錄)

3) mkdir /tmp/kafka-logs  (建立日誌目錄)

4) /usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties (啟動kafka)

啟動之後可以嘗試一些簡單的操作驗證是否安裝正確:

建立topic:/usr/local/kafka/bin/kafka-topic.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

往topic裡傳送訊息: /usr/local/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

 Test message 1

 Test message 2