項目描述

本項目是個簡單的kafka集群簡單生產者和消費者實例，生產者能生產消息，消費者能消費消息，這里將消費的消息存入了mysql數據庫，適合剛kafka剛入門的朋友借鑒使用，里面的zookeeper集群和kafka集群的地址需要修改為自己的。

運行環境

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

支持windows下集群

項目技術(必填)

java+maven+log4j

jar包文件

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

提取碼：yuvg

數據庫文件

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

提取碼：y9u9

項目截圖(必填)

運行截圖(必填)

先啟動Main在啟動ConsumerMain

這是查看的運行日志

windows下目錄在項目同一個磁盤目錄的D:\kafkaProjects\logs

控制臺日志同上面的文件日志

生產者日志

消費者日志

注意事項

1.注意修改自己的集群地址以及消費者消費消息存入數據庫地址

2.數據庫保存消息跑出如下異常

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

3.如果zookeeper和kafka是單個實例，不集群，則修改ProducerUtil.java和ConsumerUtil.java

4.必須先啟動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下如何啟動kafka請參考https://www.jianshu.com/p/ce203d4e2f41

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。