【问题标题】:Kafka connect not working?卡夫卡连接不起作用?
【发布时间】:2023-04-03 04:17:01
【问题描述】:

在浏览apache官方页面时

https://kafka.apache.org/quickstart

一个文本文件被创建为

echo -e "foo\nbar" > test.txt

要使用 kakfa 连接,请使用以下命令

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

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

【问题讨论】:

  • Do not post images of code or errors! 图片和屏幕截图可以很好地添加到帖子中,但请确保帖子在没有它们的情况下仍然清晰有用。如果您发布代码或错误消息的图像,请确保您也复制并粘贴或直接在帖子中输入实际代码/消息。
  • 是的,问题中已经提到了所有代码和页面描述以及问题屏幕截图以供清除@Rob谢谢
  • Address already in use... 不是 Kafka 问题。你正在运行其他与之冲突的东西
  • @cricket_007 我杀死了最初创建的test 主题,删除了偏移量然后再次启动kafka,它显示WARN FAILED org.eclipse.jetty.server.Server@652ce654: java.net.BindException: Address already in useKafka Connect stopped。如何解决这个问题?
  • 您必须停止在该端口上运行的其他进程。根据所提供的信息,我无法告诉你这是什么。您的端口是 8083 stackoverflow.com/a/12737392/2308683可以更改 Kafka Connect 端口...查看 8083 的属性文件,然后选择一个不同的数字,例如 8084

标签: apache-kafka apache-kafka-connect


【解决方案1】:

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

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

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

rest.port=18083

18083 是一个可用端口。

【讨论】:

    猜你喜欢
    • 2017-11-14
    • 1970-01-01
    • 2023-02-15
    • 2020-08-27
    • 2016-09-03
    • 2018-01-18
    • 2017-03-02
    • 1970-01-01
    相关资源
    最近更新 更多