感谢你帮我解答,我已经找到问题所在了,是因为cloudera manager
自己有自己的配置文件,所以server.properties
并不生效。
你客户端配置的是 loshu-bdt03 吗?
是的,这些都试过了。另外我是用cloudera manager通过parcel安装的kafka,server.properites
似乎不会被用到。另外我查看了下log,报的错误是controller一直无法连通brokers:
2018-09-03 14:14:22,336 WARN kafka.controller.RequestSendThread: [Controller-115-to-broker-113-send-thread]: Controller 115's connection to broker loshu-bdt03:1 (id: 113 rack: null) was unsuccessful
java.io.IOException: Connection to loshu-bdt03:1 (id: 113 rack: null) failed.
at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:68)
at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:269)
at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:223)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64)
2018-09-03 14:14:22,384 WARN org.apache.kafka.clients.NetworkClient: [Controller id=115, targetBrokerId=115] Connection to node 115 could not be established. Broker may not be available.
2018-09-03 14:14:22,384 WARN kafka.controller.RequestSendThread: [Controller-115-to-broker-115-send-thread]: Controller 115's connection to broker loshu-bdt05:1 (id: 115 rack: null) was unsuccessful
java.io.IOException: Connection to loshu-bdt05:1 (id: 115 rack: null) failed.
at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:68)
at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:269)
at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:223)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:64)
这是什么问题呢