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 ?

Reply via email to