kafka安裝所需要的環境：

1.java環境

2.安裝zookeeper

1.獲取kafka安裝檔案

命令（opt目錄下）：

wget https://archive.apache.org/dist/kafka/0.9.0.1/kafka_2.10-0.9.0.9.tgz

解壓命令：

tar zxf kafka_2.10-0.9.0.1.tgz

進入配置檔案目錄：

[[email protected] config]# cd /opt/kafka_2.10-0.9.0.1/config/

編輯

vi server.properties

修改引數如下：

broker.id=0
advertised.port=9092
advertised.host.name=192.168.230.131
num.network.threads=3
num.io.threads=8
log.dirs=/opt/kafka_2.10-0.9.0.1/kafkalogs
socket.receive.buffer.bytes=102400
num.partitions=1
log.retention.hours=168
message.max.byte=5242880
default.replication.factor=2
replica.fetch.max.bytes=5242880
log.retention.check.interval.ms=300000
log.cleaner.enable=false
zookeeper.connect=192.168.230.131:2181
 

切到bin目錄下：

啟動kafka

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

建立topic:

./kafka-topics.sh --create --zookeeper 127.0.0.1:2182 --topic test_topic --replication-factor 1 --partitions 8

至此 kafka已經啟動，開始測試：

在伺服器上啟動生產者：

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

在伺服器上啟動消費者：

./bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test_topic --from-beginning