您當前的位置:首頁 >> 買車
Docker下安裝kafka,以及java實現生產者的過程
發布時間:2019-08-09
 

我們的環境是centos7

第一步:安裝docker 我們要是第一安裝docker 會有很多坑要踩,

這里我這直接說,避開坑的安裝方式。

第一步: 更新Linux的內核, yum update

第二步:通過管理員安裝 docker 容器 sudo yum install docker (切記一定要這么安裝)

第三步:啟動docker容器 systemctl start docker

第四步:檢查docker容器是否啟動成功 查看容器狀態 systemctl status docker

因為kafka需要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

中間兩個參數的140.143.134.205:改為本機的IP地址,不設置可能會導致在別的機器上訪問不到kafka。

測試kafka

1.首先要從docker中進入kafka docker exec -ti kafka /bin/bash

2.進入kafka所在目錄中 cd opt/kafka_2.12-1.1.0/

接下來我們可以直接使用kafka 自己命令行的方式,測試自己的生產和消費

1.首先創建topic bin/kafka-topics.sh --create --zookeeper 140.143.134.205:2181 --replication-factor 1 --partitions 1 --topic kafka-test

2.我們先來一個生產者 bin/kafka-console-producer.sh --broker-list 140.143.134.205:9092 --topic kafka-test

3. 來一個消費者 bin/kafka-console-consumer.sh --bootstrap-server 140.143.134.205:9092 --topic kafka-test --from-beginning

Docker下安裝kafka,以及java實現生產者的過程

接下來我們看java代碼中怎么實現一個生產者

先看看效果圖

Docker下安裝kafka,以及java實現生產者的過程

這個圖就是,右側是java程序在生產,左側的命令行接收

Docker下安裝kafka,以及java實現生產者的過程
内蒙古十一选五开奖图