kafka安裝和基本使用

2.將檔案解壓

3.進入 kafka_2.9.2-0.8.1.1/config 目錄

4.修改 server.properties檔案

引數

參考引數值

broker.id 0

port

9092

log.dirs

kafka_2.9.2-0.8.1.1/logs

zookeeper.connect

zookeeper31:2181,

zookeeper32:2181,zookeeper33:2181

5.修改hosts檔案

vi /etc/hosts

192.168.178.129 zookeeper31
192.168.178.130 zookeeper32
192.168.178.131 zookeeper33

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

bin/kafka-topics.sh --create --zookeeper zookeeper31:2181 --replication-factor 1 --partitions 3 --topic mydemo1

bin/kafka-topics.sh --list --zookeeper zookeeper31:2181 --topic mydemo1

bin/kafka-topics.sh --describe --zookeeper zookeeperr31:2181 --topic mydemo1

dddd引數111

1.複製server.properties 為 server1.properties,並修改如下內容

引數

參考引數值

1.傳送訊息

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mydemo1

bin/kafka-console-consumer.sh --zookeeper zookeeper31:2181 --topic mydemo1

KaFka 安裝與基本使用

學了有一段時間的大資料了，學習新的元件，大部分安裝可以分為三步 上傳解壓，配置檔案，啟動。分享一下我的kafka安裝包 1 上傳解壓 2 進入到 usr local soft kafka 2.10 0.8.2.2 config 目錄下，修改server.properties檔案 3 因為kafka是...

安裝和使用kafka

啟動建立主題 模擬生產者和消費者 一部已經安裝好的zookeeper虛擬機器 上傳kafka安裝包 為了方便執行，配置一下環境變數 export kafka home opt software kafka kafka 2.12 1.1.0 export path path kafka home bi...

Kafka安裝和簡單使用

首先安裝zookeeper和scala 安裝zookeeper root hadoop001 conf cp zoo sample.cfg zoo.cfg root hadoop001 conf vi zoo.cfg the number of milliseconds of each tick t...