Hi, Just upgraded my Kafka test environment from 1.1 to 2.2.1. What I did: 1) Untarred Scala 2.11-Kafka 2.2.1 file in /opt directory (BTW: OS = CentOS 7.6) which creates directory kafka_2.11-2.2.1 2) Removed symbolic link "kafka" from old environment kafka_2.11-1.1.0 3) Created a new symbolic link "kafka" to the new directory kafka_2.11-2.2.1 4) Started zookeeper (no errors) 5) Added inter.broker.protocol.version=1.1 to server.config 6) Started kafka (no errors) 7) From the bin directory: ./kafka-topics.sh --bootstrap-server localhost:9092 --list
This produces an empty list (no output). Stopping kafka and kafka-zookeeper, reverting the symbolic link to the old environment and starting kafka-zookeeper and kafka again, followed by ./kafka-topics.sh --zookeeper localhost:2181 --list gives me all my topics again. What am I doing wrong ?
