当前版本:kafka_2.12-2.8.0
、CentOS7
1. 声明
当前内容主要为本人学习和测试开启Kafka的RestApi的方式,当前内容参考官方文档
2. 基本操作
1.首先启动zookeeper,然后启动kafka
2.开始配置当前的连接器
vi config/connect-standalone.properties
主要修改
3.选择连接器
这里选择的是:connect-console-sink.properties
4.启动连接器(默认启动在8083端口)
./bin/connect-standalone.sh config/connect-standalone.properties config/connect-console-sink.properties
等待启动成功即可!
5.查看端口
netstat -ano
表示启动成功!实际是启动相应的连接器(Connector)
3. 测试访问
下面就是测试了,参考官方api
启动成功!