我为atlas服务器和kafka在ha模式下设置了一个ambari。服务器是13.146和13.252,而ambari服务器安装在13.146上。我的问题是,如果我手动停止一个kafka代理,atlas服务器就不会切换到另一个kafka代理。
例如,如果atlas服务器与13.146上id为1001的kafka代理连接,然后如果我停止同一个kafka代理,则atlas服务器应该已切换到13.252上的另一个kafka代理,但它没有。我没有切换,而是在下面提到的atlas服务器日志文件中收到一条连续的错误消息。
警告-[kafka producer network thread | producer-1:]~[producer clientid=producer-1]无法建立到节点1001的连接。代理可能不可用(网络orkclient:671)
以下是atlas服务器属性:
atlas.kafka.bootstrap.servers = x.x.13.146:6667,x.x.13.252:6667
atlas.notification.replicas = 2
atlas.kafka.zookeeper.connect = x.x.13.146:2181
暂无答案!
目前还没有任何答案,快来回答吧!