这几天在测试goldengate输出到Kafka的CDC,由于Kafka集群设置了ip限制, 由于新部署的NiFi机器申请权限的时候, j集群中某台机器ip忘了放开了.
然后就悲剧了.
开始那台机器有Kafkas是0.11的版本, 使用bin/kafka-console-consumer.sh 没连通了.
开始估计是Kafka版本的问题, OGG输出的Kafka使用了0.10的版本,测试了0.10,0.11,1.0个各版本, 都不通.
最后测试使用telnet ip port才发现问题.
不过centos7默认没有安转 telnet命令,可以使用
yum install telnet安装.