項(xiàng)目描述

本項(xiàng)目是個(gè)簡(jiǎn)單的kafka集群簡(jiǎn)單生產(chǎn)者和消費(fèi)者實(shí)例，生產(chǎn)者能生產(chǎn)消息，消費(fèi)者能消費(fèi)消息，這里將消費(fèi)的消息存入了mysql數(shù)據(jù)庫(kù)，適合剛kafka剛?cè)腴T的朋友借鑒使用，里面的zookeeper集群和kafka集群的地址需要修改為自己的。

運(yùn)行環(huán)境

jdk1.8+mysql+linux+zookeeper集群+kafka集群

支持windows下集群

項(xiàng)目技術(shù)(必填)

java+maven+log4j

jar包文件

鏈接：https://pan.baidu.com/s/1-PfrSjoGPP3WPtoP-wBpTw

提取碼：yuvg

數(shù)據(jù)庫(kù)文件

鏈接：https://pan.baidu.com/s/1e1kh8Dkqe7oz43OHR5YEEg

提取碼：y9u9

項(xiàng)目截圖(必填)

運(yùn)行截圖(必填)

先啟動(dòng)Main在啟動(dòng)ConsumerMain

這是查看的運(yùn)行日志

windows下目錄在項(xiàng)目同一個(gè)磁盤目錄的D:\kafkaProjects\logs

控制臺(tái)日志同上面的文件日志

生產(chǎn)者日志

消費(fèi)者日志

注意事項(xiàng)

1.注意修改自己的集群地址以及消費(fèi)者消費(fèi)消息存入數(shù)據(jù)庫(kù)地址

2.數(shù)據(jù)庫(kù)保存消息跑出如下異常

需要加private static final String URL = "jdbc:mysql://127.0.0.1:3306/kafka_demo?serverTimezone=UTC";

3.如果zookeeper和kafka是單個(gè)實(shí)例，不集群，則修改ProducerUtil.java和ConsumerUtil.java

4.必須先啟動(dòng)zookeeper和kafka

cd D:\kafka_2.12-2.3.0\bin\windows\

zookeeper-server-start.bat ..\..\config\zookeeper.properties

cd D:\kafka_2.12-2.3.0\bin\windows\

kafka-server-start.bat ..\..\config\server.properties

windows下如何啟動(dòng)kafka請(qǐng)參考https://www.jianshu.com/p/ce203d4e2f41

總結(jié)

以上是生活随笔為你收集整理的java kafka 集群消费_kafka集群简单生产者消费者实例的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。