卡夫卡连接不工作?

Posted

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了卡夫卡连接不工作?相关的知识,希望对你有一定的参考价值。

在浏览apache官方页面时

https://kafka.apache.org/quickstart

文本文件创建为

echo -e "foo bar" > test.txt

并使用kafka connect以下命令

bin/connect-standalone.sh config/connect-standalone.properties config/connect-file-source.properties config/connect-file-sink.properties

但是当执行上面的命令时,它会显示一条消息kafka-connect stopped

答案

其他东西使用的是Kafka Connect想要使用的相同端口。

您可以使用netstat -plnt来识别其他程序(如果进程由其他用户拥有,则需要将其作为root运行)。

如果您想让Kafka Connect使用其他端口,请编辑config/connect-standalone.properties以添加:

rest.port=18083

18083是一个可用的端口。

以上是关于卡夫卡连接不工作?的主要内容,如果未能解决你的问题,请参考以下文章

初始化 TEST 连接器后雪花卡夫卡连接器失败

雪花卡夫卡连接器限制?

卡夫卡连接 |由于操作冲突,无法完成请求

雪花卡夫卡连接器疑惑和疑问

卡夫卡连接错误:java.lang.NoClassDefFoundError:org/apache/http/conn/HttpClientConnectionManager

卡夫卡火花流工作有许多活跃的工作