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
