2017-09-25 48 views
0

异常打造主题为“主”无法在线程使用卡夫卡AdminUtils.createTopic

kafka.common.KafkaException: Failed to parse the broker info from zookeeper: 

{"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://localhost:9093"],"jmx_port":-1,"host":"localhost","timestamp":"1506322454462","port":9093,"version":4} 

,这是什么可能的解决方案?

我已经检查到处,但似乎没有工作。

回答

0

检查代理和客户端上的kafka版本,可能您使用的是过时的客户端。

+0

每当我尝试创建toipc时,在Zookeeper终端处得到“EndOfStreamException:无法从客户端会话id 0x15eb7cf1d750009读取其他数据,可能客户端已关闭套接字”。并使用依赖关系“org.apache.kafka”%“kafka_2.11”%“0.10.0.1”用sbt构建 –

相关问题