Hi,

I have strange problem. I have kafka 9 cluster of 3 nodes. I removed all
topics from zookepper, but when I query topics using Java High Level
consumer it returns all three removed kafka topics. But how this is
possible when I removed them manually, by going into zookeeper shell and
removing them, ?
My java code;

 props.put("bootstrap.servers", server:9092");

        props.put("key.deserializer",
"org.apache.kafka.common.serialization.StringDeserializer");

        props.put("value.deserializer",
"org.apache.kafka.common.serialization.StringDeserializer");


        Map<String, List<PartitionInfo>> topics =  new KafkaConsumer<>(props
).listTopics();

        System.out.println (topics);



best,

Shahab

Reply via email to