bigdata-Strom整合Kafka

一、啓動zookeeper

cd $ZK_HOME/bin
./zkServer.sh start

jps  : QuorumPeerMaiin
Prot : 2181

二、啓動kafka

(1)啓動

cd $KAFKA_HOME/bin
./kafka-server-start.sh -daemon $KAFKA_HOME/config/server.properties

jps : Kafka
端口 : 9092

三、建立topic
kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test-topic-180216-01

四、測試是否正常

 （1）起一個發送消息
  kafka-console-producer.sh --broker-list localhost:9092 --topic test-topic-180216-01

 （2）起一個消費消息

  kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test-topic-180216-01

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

  說明：--from-beginning 每次都從頭消費

  # 老的寫法
  kafka-console-consumer.sh --zookeeper localhost:2181 --topic test-topic-180216-01

 

五、查看topic信息

   查看描述
        kafka-topics.sh --describe --zookeeper localhost:2181

    查看全部topic
        kafka-topics.sh --list --zookeeper localhost:2181

    根據topic名稱查看內容         kafka-topics.sh --describe --zookeeper localhost:2181 --topic test-topic-180216-01