做网站一般都选哪家,做婚纱网站是怎么确认主题,帮别人做网站的单子,北京做家教的的网站个人名片#xff1a; #x1f405;作者简介#xff1a;一名大三在校生#xff0c;热爱生活#xff0c;爱好敲码#xff01; \ #x1f485;个人主页 #x1f947;#xff1a;holy-wangle ➡系列内容#xff1a; #x1f5bc;️ tkinter前端窗口界面创建与优化 … 个人名片 作者简介一名大三在校生热爱生活爱好敲码 \ 个人主页 holy-wangle ➡系列内容 ️ tkinter前端窗口界面创建与优化 ️ Java实现ATP小系统 ✨个性签名 不积跬步无以至千里不积小流无以成江海 今天我们聊聊如何使用maxwell监控mysql的数据改变然后将数据传输到kafka的过程。 首先我们是不是要有mysqlmaxwellkafka的环境吧环境我就默认各位都部署好了。 第一步配置maxwell的bin目录下的config.properties(刚安装的时候这个文件叫config.properties.example我这里把这个文件改名了) 添加一下内容
log_levelinfoproducerkafka
kafka.bootstrap.servershadoop102:9092,hadoop103:9092#kafka topic配置
kafka_topictopic_db# mysql login info
hosthadoop102
usermaxwell
passwordmaxwell
jdbc_optionsuseSSLfalseserverTimezoneAsia/Shanghai 保存退出 然后在hadoop103的节点启动消费者模式,命令是
bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --topic topic_db 跟着我们在hadoop102节点上面启动maxwell要有maxwell进程才行哦然后输入命令
/opt/software/maxwell/bin/maxwell-bootstrap --database gmall --table user_info --config /opt/software/maxwell/config.properties 我这里是获取mysql中gmall.user_info表中的数据进来消费。
下面是图示 感谢各位的观看创作不易能不能给哥们来一个点赞呢
好了今天的分享就这么多了有什么不清楚或者我写错的地方请多多指教
私信评论我呗
关注我下一篇不迷路哦
