Confluent本地单节点安装
0.前言
【点击这里查看confluent建立连接器与KsqlDB的使用】
我的环境
| 名字 | 版本 |
|---|---|
| 操作系统 | centos7 |
| confluent | 5.5.1（商业版） |
| jdk | 1.8 |
1.安装jdk【建议安装】
上传到linux的/usr/local/目录下解压
tar -zxvf jdk1.8.0_144.tar.gz
vi /etc/profile
#java
export JAVA_HOME=/usr/local/jdk1.8.0_144/
export PATH=$JAVA_HOME/bin:$PATH
使环境变量生效
source /etc/profile
输入java -version查看是否安装成功
[root@hadoop89]# java -version
java 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)
2.下载confluent
点击这里查看官网
点击这里下载各个版本
confluent社区版开源免费，商业版1个kafka broker免费，两个或两个以上kafka broker有30天试用期，试用期过后需要购买密钥，否则无法使用，
这里我安装商业版单个broker。具体内容参考下图
3.安装confluent
上传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目录下
vi /etc/profile
#confluent
export CONFLUENT_HOME=/usr/local/confluent-5.5.1
export PATH=$CONFLUENT_HOME/bin:$PATH
使环境变量生效
source /etc/profile
输入confluent查看是否安装成功
4.启停confluent
启动confluent，一次无法全启动，建议多启动几次。
cofluent local start
关闭confluent
confluent local stop
查看confluent各个组件状态
confluent local status
启动后可能有一定延迟后浏览器才可以访问页面
ip:9021
cd /tmp/confluent.WGkeIh47
cd connect
cat connect.stdout
5.设置日志不被清除
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 override
v /tmp 1777 root root 10d
v /var/tmp 1777 root root 30d
# Exclude namespace mountpoints created with PrivateTmp=yes
x /tmp/systemd-private-%b-*
X /tmp/systemd-private-%b-*/tmp
x /var/tmp/systemd-private-%b-*
X /var/tmp/systemd-private-%b-*/tmp
x /tmp/confluent*
