假设已经安装好了kafka 集群,安装目录是: KAFKA_BASE=/opt/kafka。
步骤1
kafka connect 集群安装配置。
vim $KAFKA_BASE/config/connect-distributed.properties
设置以下参数的值
bootstrap.servers=10.10.10.11:9092,10.10.10.12:9092,10.10.10.13:9092
说明
kafka connect 是kafka 集群自带的服务,这里只需要修改一下kafka connect 的
配置文件。
步骤2
GDR 和GDS 安装,GDR 和GDS 是运行在kafka connect 集群上的jar 包,安
装时需要把GDR 和GDS 所有的jar 包放在所有节点的$KAFKA_BASE/libs 目
录下;
当前GDR 和GDS 运行时包含的jar 包有:
connect-crossdomain-1.0.1.jar
gbase-connector-java-8.3.81.53-build52.6-bin.jar
hive-jdbc-2.2.0-standalone.jar
ifxjdbc.jar
kafka-connect-jdbc-4.0.0.jar
mysql-connector-java-5.1.17.jar
ojdbc6.jar