在端口 8083 上我正在运行 Influxdb,我什至可以打开 GUIhttp://本地主机:8083 http://localhost:8083
现在来到kafka,这里我指的是按照https://kafka.apache.org/quickstart https://kafka.apache.org/quickstart
通过以下命令启动文件夹 /opt/zookeeper-3.4.10 中的 Zookeeeper:bin/zkServer.sh start
因此,zookeeper 现在已启动,在 /opt/kafka_2.11-1.1.0 文件夹下启动 kafka,如下所示:
bin/kafka-server-start.sh config/server.properties
创建一个名为“test”的主题,其中包含单个分区和一个副本:
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
主题已创建,可以使用命令签入:
bin/kafka-topics.sh --list --zookeeper localhost:2181
到目前为止,一切都很好并且经过调整。
现在我需要使用“卡夫卡连接“导入/导出数据的组件。
所以我创建一个种子数据:echo -e "foo\nbar" > test.txt
现在使用连接器配置“卡夫卡连接“ 上班 :bin/connect-standalone.sh config/connect-standalone.properties config/connect-file-source.properties config/connect-file-sink.properties
运行上面的命令后我得到:Address already in use
Kafka connect has stopped
我什至改变了rest.port=8084
在 /opt/kafka_2.11-1.1.0/config/connect-distributed.properties 中,这样它就不会与 8083 上已有的 influxdb 发生冲突。我仍然得到相同的结果Address already in use
,
Kafka connect has stopped
如屏幕截图所示。