我們的環(huán)境是centos7
第一步：安裝docker?我們要是第一安裝docker?會有很多坑要踩，
這里我這直接說，避開坑的安裝方式。
? ? ? ?第一步：?更新Linux的內(nèi)核，? ? yum update?
? ? ? ?第二步：通過管理員安裝 docker 容器? ? ? sudo yum install docker? ?（切記一定要這么安裝）
? ? ? ?第三步：啟動docker容器? ? ? systemctl start docker?
? ? ? ?第四步：檢查docker容器是否啟動成功 查看容器狀態(tài)? ? ? ? systemctl status docker?
因?yàn)閗afka需要zookeeper? 所以我們需要先
? ? ? ? ? ?1. 安裝zookeeper? ? docker run -d --name zookeeper -p 2181:2181 -t wurstmeister/zookeeper
? ? ? ? ? ?2.安裝kafka? ? ?
????????????????????docker run -d --name kafka? ? ?-p 9092:9092?
????????????????????-e KAFKA_BROKER_ID=0?
????????????????????-e KAFKA_ZOOKEEPER_CONNECT=140.143.134.205:2181?
????????????????????-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://140.143.134.205.128:9092?
? ? ? ? ? ? ? ? ? ? ? -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -t wurstmeister/kafka
????????????????????????中間兩個參數(shù)的140.143.134.205:改為本機(jī)的IP地址，不設(shè)置可能會導(dǎo)致在別的機(jī)器上訪問不到kafka。
測試kafka
? ? ? ? 1.首先要從docker中進(jìn)入kafka ? ? docker exec -ti kafka /bin/bash
? ? ? ?2.進(jìn)入kafka所在目錄中? ? ? cd opt/kafka_2.12-1.1.0/
接下來我們可以直接使用kafka? 自己命令行的方式，測試自己的生產(chǎn)和消費(fèi)
? ? ? ? ? ? 1.首先創(chuàng)建topic? ? ?bin/kafka-topics.sh --create --zookeeper 140.143.134.205:2181 --replication-factor 1 --partitions 1 --topic kafka-test
? ? ? ? ? ? 2.我們先來一個生產(chǎn)者? ? ?bin/kafka-console-producer.sh --broker-list 140.143.134.205:9092 --topic kafka-test
? ? ? ? ? ?3.?來一個消費(fèi)者? ?bin/kafka-console-consumer.sh --bootstrap-server 140.143.134.205:9092 --topic kafka-test --from-beginning
? ??????????????????
接下來我們看java代碼中怎么實(shí)現(xiàn)一個生產(chǎn)者
先看看效果圖
? ? ? ? ? ? ? ? 這個圖就是，右側(cè)是java程序在生產(chǎn)，左側(cè)的命令行接收
需要源碼留言，
