【问题标题】:Running Kafka Mirror Maker 2 in specific port在特定端口运行 Kafka Mirror Maker 2
【发布时间】:2020-08-29 09:58:50
【问题描述】:

为了在两个 DC 之间复制数据,我设置了 Kafka MM2。它运行正常。但是每次我重新启动时,它都是从不同的端口启动的。

为了监控这个应用程序,如果它总是在同一个端口上运行会更好,这样我们就可以监控那个端口是否有任何警报。

对于 kafka,我们将手动指定端口。但是对于 MirrorMaker,没有在属性中手动设置端口的选项。我还尝试了各种选项,例如设置 -Dserver.port。但他们都没有工作。

任何人都可以为此提供解决方案吗?!

【问题讨论】:

    标签: apache-kafka apache-kafka-mirrormaker


    【解决方案1】:

    listeners 是确定绑定服务器端口的 Kafka Connect 属性

    例如,将其设为 8181 端口,listeners=HTTP://0.0.0.0:8181

    rest.port 属性已弃用

    【讨论】:

    • 我已尝试提供此属性。但它仍然没有拿起我给的那个。我在 connect-mirror-maker.properties 中给出了这个属性。除此之外,我还尝试了rest.port、rest.advertised.port。但没有一个奏效。我是否遗漏了什么?
    • 其实只是listeners - kafka.apache.org/documentation/#connect_restsource code is here 用于解析属性的位置
    • 从源代码和日志中,我只能看到监听器的空值。如前所述,我已尝试设置 listeners 属性的值。但它似乎没有被捡起。我还记录了workerProps。但不存在与侦听器或端口相关的属性。我是否缺少任何东西?
    • 您使用的是connect-mirror-maker 还是connect-distributed?两者都加载包含侦听器配置的 DistributedConfig 类
    • 我正在使用 connect-mirror-maker。我可以在 WorkerConfig 类中找到填充的 listeners 属性。但是他们正在将值设置为空的地图。此外,connect-mirror-maker.properties 将用作 MirrorMakerConfig。但是 DistributedConfig 正在填充 workerProps,我看不到与侦听器相关的属性。如果在 connect-mirror-maker.proeprties 中给出,是否需要添加前缀?
    【解决方案2】:

    我尝试了很多不同的方法,最后决定采用以下方法:

    1. 启动mirrormaker时,我会手动打开socketconnection到某个固定端口
    2. 将监视此固定端口的警报。如果此端口关闭,则表示 mirrormaker 进程已关闭。

    我已经对此进行了测试,它可以正常工作。

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2019-11-27
      • 2020-03-22
      • 1970-01-01
      相关资源
      最近更新 更多