1、下載kafka
cd到/usr/local目錄下,執行命令:wget https://www-us.apache.org/dist/kafka/2.4.0/kafka_2.13-2.4.0.tgz下載
2、解壓kafka_2.13-2.4.0.tgz文件
tar -zxvf kafka_2.13-2.4.0.tgz
3、啟動服務
3.1 啟動zookeeper
啟動zk有兩種方式,第一種是使用kafka自己帶的一個zk:bin/zookeeper-server-start.sh config/zookeeper.properties
另一種是使用其它的zookeeper,可以位於本機也可以位於其它地址。
這種情況需要修改kafka中config下面的server.properties里面的zookeeper地址 。例如zookeeper.connect=192.168.213.11:2181
成功啟動zookeeper后才可以啟動kafka。
3.2 修改kafka下的config/server.properties
修改log.dirs=/usr/local/kafka_2.13-2.4.0/kafka_logs //日志文件路徑 記得創建日志文件目錄
修改advertised.listeners=PLAINTEXT://192.168.1.19:9092 //配置對外訪問的ip 如果不配置外網無法訪問
3.2 啟動kafka
執行命令:bin/kafka-server-start.sh config/server.properties 啟動kafka
kafka如果直接啟動會出現問題,就是信息會打印在控制台,就會出現在控制台。
然后關閉窗口,kafka隨之關閉,然后啟動以下的命令就可以實現。
bin/kafka-server-start.sh config/server.properties 1>/dev/null 2>&1 &
4、創建topic
執行命令: bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test 創建topic
創建一個名為test的topic,只有一個副本,一個分區
通過list命令查看剛剛創建的topic
執行命令:bin/kafka-topics.sh -list -zookeeper localhost:2181 查看
5、啟動producer並發送消息啟動producer
執行命令:bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test 啟動producer
之后就可以發送消息了,例如:
This is a message
This is another message
6、然后在另一個終端中,啟動consumer
執行命令:bin
/kafka-console-consumer
.sh --bootstrap-server localhost:9092 --topic
test
--from-beginning