1. 程式人生 > >Linux下圖示安裝Kafka

Linux下圖示安裝Kafka

一:Kafka的下載安裝.

       1. Kafka官網.

       2. 官網下載.

       

    3. Linux下wget+url即可.

     wget http://mirror.bit.edu.cn/apache/kafka/2.0.0/kafka_2.12-2.0.0.tgz

     

   4. 解壓到指定的目錄.

    tar -zxvf kafka_2.12-2.0.0.tgz -C /usr/local

  

Kafka的目錄.

配置檔案的目錄.(config)

二 . Kafka的配置啟動.

      2.1 vim server.properties.

      broker.id=0(broker的全域性唯一編號,不能重複).

      log.dirs=/tmp/kafka-logs

      zookeeper.connect=192.168.217.134:2181(ZooKeeper叢集配置多個).

      zookeeper.connection.timeout.ms=6000

      2.2 啟動Zookeeper.

     2.3 啟動Kafka.

       kafka目錄下:sh bin/kafka-server-start.sh config/server.properties

         jps(另外一個視窗執行命令)

 啟動生產者:(生產三條訊息.Hello,Kafka,Test).

 sh kafka-console-producer.sh --broker-list localhost:9092 --topic testkafka

 

啟動消費者:

0.9以下的版本使用這個--zookeeper引數.

0.9以上的版本使用如下的方式啟動消費者.

sh kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testkafka --from-beginning

輸出三條訊息.

啟動三個終端.(啟動一個kafka Server一個終端,生產者一個終端,消費者一個終端).

關閉(Ctrl+C).