问题描述
为了在两个DC之间复制数据,我安装了Kafka MM2。它运行正常。但是每次重新启动时,它都是从不同的端口启动的。
为了监视此应用程序,最好始终运行在同一端口,以便我们可以监视该端口是否有警报。
对于kafka,我们将手动指定端口。但是对于MirrorMaker,没有选项可以在属性中手动设置端口。我也尝试了各种选项,例如设置-Dserver.port。但是他们都没有工作。
任何人都可以为此提供解决方案吗?!
解决方法
listeners
是确定绑定服务器端口的Kafka Connect属性
例如,将其设置为端口8181,listeners=HTTP://0.0.0.0:8181
rest.port
属性已弃用
我尝试了许多不同的方法,最终决定采用以下方法:
- 启动mirrormaker时,我将手动打开与某些固定端口的套接字连接
- 将监视此固定端口的警报。如果此端口出现故障,则表明mirrormaker进程已关闭。
我已经对此进行了测试,并且可以正常工作。