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