CentOS 7下安裝Kafka單機版

詳細安裝步驟

  1. 下載kafka_2.10-0.10.0.0.tgz到/data/soft目錄app

  2. 進入解壓目錄(在此爲/data/app/Kafka/kafka_2.10-0.10.0.0/bin),啓動zookeeper服務。能夠在命令的結尾加個&符號,這樣服務就能夠在後臺運行code

  3. 啓動kafka服務server

kafka-server-start.sh ../config/server.properties &

ps -ef | grep kafka查看,觀察到zookeeper和kafka服務已啓動kafka

驗證

  1. 建立一個叫"test1234"的topic,它只有一個分區,一個副本:
kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1234

能夠用list查看建立的topicit

kafka-topics.sh --list --zookeeper localhost:2181
  1. 發送消息。運行producer並在控制檯中輸一些消息,這些消息將被髮送到服務端
kafka-console-producer.sh --broker-list localhost:9092 --topic test1234
  1. 在另外一個終端開啓consumer,能夠讀取到剛纔發出的消息並輸出。
kafka-console-consumer.sh --zookeeper localhost:2181 --topic test1234 --from-beginning
相關文章
相關標籤/搜索