云南快三平台app下载—官方网址22270.COM代码广告位
倪卟懂的gravatar头像
倪卟懂2019-08-16 14:24:03

ƻ⡪ٷַ22270.COM_kafka集群简单生产者消费者实例

项目描述

本项目是个简单的ƻ⡪ٷַ22270.COM_kafka集群简单生产者和消费者实例,生产者能生产消息,消费者能消费消息,这里将消费的消息存入了mysql数据库,适合刚kafka刚入门的朋友借鉴使用,里面的zookeeper集群和ƻ⡪ٷַ22270.COM_kafka集群的地址需要修改为自己的。

运行环境

jdk1.8+mysql+linux+zookeeper集群+ƻ⡪ٷַ22270.COM_kafka集群

支持windows下集群

项目技术(必填)

java+maven+log4j

jar包文件

链接:http://pan.baidu.com/s/1-PfrSjoGPP3WPtoP-wBpTw
提取码:yuvg

数据库文件

链接:http://pan.baidu.com/s/1e1kh8Dkqe7oz43OHR5YEEg
提取码:y9u9

项目截图(必填)

ƻ⡪ٷַ22270.COM_kafka集群简单生产者消费者实例

ƻ⡪ٷַ22270.COM_kafka集群简单生产者消费者实例

ƻ⡪ٷַ22270.COM_kafka集群简单生产者消费者实例

ƻ⡪ٷַ22270.COM_kafka集群简单生产者消费者实例

运行截图(必填)

先启动Main在启动ConsumerMain

这是查看的运行日志

ƻ⡪ٷַ22270.COM_kafka集群简单生产者消费者实例

windows下目录在项目同一个磁盘目录的D:\kafkaProjects\logs

ƻ⡪ٷַ22270.COM_kafka集群简单生产者消费者实例

ƻ⡪ٷַ22270.COM_kafka集群简单生产者消费者实例

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

生产者日志

ƻ⡪ٷַ22270.COM_kafka集群简单生产者消费者实例

消费者日志

ƻ⡪ٷַ22270.COM_kafka集群简单生产者消费者实例

注意事项

1.注意修改自己的集群地址以及消费者消费消息存入数据库地址

2.数据库保存消息跑出如下异常

ƻ⡪ٷַ22270.COM_kafka集群简单生产者消费者实例

需要加

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

ƻ⡪ٷַ22270.COM_kafka集群简单生产者消费者实例

3.如果zookeeper和kafka是单个实例,不集群,则修改ProducerUtil.java和ConsumerUtil.java

ƻ⡪ٷַ22270.COM_kafka集群简单生产者消费者实例

ƻ⡪ٷַ22270.COM_kafka集群简单生产者消费者实例

4.必须先启动zookeeper和kafka

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

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

ƻ⡪ٷַ22270.COM_kafka集群简单生产者消费者实例

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

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

ƻ⡪ٷַ22270.COM_kafka集群简单生产者消费者实例

windows下如何启动kafka请参考http://www.jianshu.com/p/ce203d4e2f41

云南快三平台app下载—官方网址22270.COM代码广告位

打赏

已有1人打赏

云南快三平台app下载—官方网址22270.COM代码官方的gravatar头像

文件名:kafka-simple-demo.zip,文件大小:18.8K下载
云南快三平台app下载—官方网址22270.COM代码云南快三平台app下载—官方网址22270.COM近下载分享源代码列表云南快三平台app下载—官方网址22270.COM近下载
860595563 LV119月30日
月亮月亮星星星星星星
z_yong76 LV248月26日
太阳月亮月亮
happy栋 LV88月26日
月亮月亮
云南快三平台app下载—官方网址22270.COM代码云南快三平台app下载—官方网址22270.COM近浏览分享源代码列表云南快三平台app下载—官方网址22270.COM近浏览
周青龙7小时前
暂无贡献等级
jiajia91323 LV1812月12日
太阳星星星星
安安an LV1612月5日
太阳
rad911 LV1111月30日
月亮月亮星星星星星星
boy_shenxiang LV311月27日
星星星星星星
lelelada LV511月27日
月亮星星
chenjun66611月19日
暂无贡献等级
yliu123 LV711月18日
月亮星星星星星星
chengs123 LV211月13日
星星星星
哈哈zr LV1011月12日
月亮月亮星星星星
云南快三平台app下载—官方网址22270.COM代码广告位
顶部客服微信二维码底部
>扫描二维码关注云南快三平台app下载—官方网址22270.COM代码为好友扫描二维码关注云南快三平台app下载—官方网址22270.COM代码为好友