本文共 2292 字,大约阅读时间需要 7 分钟。
【点击这里查看confluent建立连接器与KsqlDB的使用】
我的环境
名字 | 版本 |
---|---|
操作系统 | centos7 |
confluent | 5.5.1(商业版) |
jdk | 1.8 |
上传到linux的/usr/local/
目录下解压
tar -zxvf jdk1.8.0_144.tar.gz
配置环境变量,修改/etc/profile
文件
vi /etc/profile
添加以下内容
#javaexport JAVA_HOME=/usr/local/jdk1.8.0_144/export PATH=$JAVA_HOME/bin:$PATH
使环境变量生效
source /etc/profile
输入java -version
查看是否安装成功
[root@hadoop89]# java -versionjava version "1.8.0_144"Java(TM) SE Runtime Environment (build 1.8.0_144-b01)Java HotSpot(TM) 64-Bit Server VM (build 25.144-b01, mixed mode)
点击查看官网
点击百度网盘下载V5.5.1商业版本, 提取码:6x48
点击下载各个版本
confluent社区版开源免费,商业版1个kafka broker免费,两个或两个以上kafka broker有30天试用期,试用期过后需要购买密钥,否则无法使用,
这里我安装商业版单个broker
。具体内容参考下图
上传confluent-5.5.1-2.12.tar.gz
到/usr/local/
目录下解压
tar -zxvf confluent-5.5.1-2.12.tar.gz
上传需要的mysql、sql server、oracle等的驱动包到解压后的confluent的/share/java/kafka-connect-jdbc
目录下
配置环境变量,修改/etc/profile
文件
vi /etc/profile
添加以下内容
#confluentexport CONFLUENT_HOME=/usr/local/confluent-5.5.1export PATH=$CONFLUENT_HOME/bin:$PATH
使环境变量生效
source /etc/profile
输入confluent
查看是否安装成功
confluent可以实时将不同数据库的数据同步到其他数据库, 需要上传相关数据库的驱动包
点击下载驱动包, 若失效请留言评论联系我获取
上传到$CONFLUENT_HOME/share/java/kafka-connect-jdbc
目录下
cd $CONFLUENT_HOME/share/java/kafka-connect-jdbc
启动confluent,一次无法全启动,建议多启动几次。
cofluent local start
关闭confluent
confluent local stop
查看confluent各个组件状态
confluent local status
启动后可能有一定延迟后浏览器才可以访问页面
ip:9021
查看日志,
WGkeIh47
为随机生成,哪儿个组件报错就查看哪儿个组件下的日志。
cd /tmp/confluent.WGkeIh47
#举例 如查看连接器报错日志cd connectcat connect.stdout
confluent启动和部分数据依赖于临时文件下的内容, 所以要设置
/tmp
下关于confluent的文件不被清理
vi /usr/lib/tmpfiles.d/tmp.conf
添加x /tmp/confluent*
,如下
# This file is part of systemd.## systemd is free software; you can redistribute it and/or modify it# under the terms of the GNU Lesser General Public License as published by# the Free Software Foundation; either version 2.1 of the License, or# (at your option) any later version.# See tmpfiles.d(5) for details# Clear tmp directories separately, to make them easier to overridev /tmp 1777 root root 10dv /var/tmp 1777 root root 30d# Exclude namespace mountpoints created with PrivateTmp=yesx /tmp/systemd-private-%b-*X /tmp/systemd-private-%b-*/tmpx /var/tmp/systemd-private-%b-*X /var/tmp/systemd-private-%b-*/tmpx /tmp/confluent*
转载地址:http://nduzi.baihongyu.com/