在特定端口中运行Kafka Mirror Maker 2

问题描述

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

为了监视此应用程序,最好始终运行在同一端口,以便我们可以监视该端口是否有警报。

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

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

解决方法

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

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

rest.port属性已弃用

,

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

  1. 启动mirrormaker时,我将手动打开与某些固定端口的套接字连接
  2. 将监视此固定端口的警报。如果此端口出现故障,则表明mirrormaker进程已关闭。

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