So, my Kafka is kerberized and all works well
However when trying to connect with missing SASL properties Kafka doesn’t fail. 
It simply hangs indefinitely.
Here is the example code;

Properties props = new Properties();
props.put("bootstrap.servers", "ubuntu.oleg.com<http://ubuntu.oleg.com>:9095");
props.put("group.id", "securing-kafka-group");
props.put("key.deserializer", 
"org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", 
"org.apache.kafka.common.serialization.StringDeserializer");
KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.listTopics();

So, it hangs on listTopics(). I think one would expect it to fail. Am I wrong?

Thanks
Oleg

Reply via email to