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

報錯詳情

kafka.common.KafkaException: Failed to parse the broker info from zookeeper: {"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://master:9092"],"jmx_port":-1,"host":"master","timestamp":"1586670217443","port":9092,"version":4}
           

分析：

因為我虛拟機中的kafka是1.1.0的，然後我的maven中的kafka是0.9.0.0的版本，版本不相容。

解決辦法：

把maven中kafka的版本提高到1.x的版本