Hi, I'm trying a simple console producer & consumer test on a broker with SSL enabled. listeners=PLAINTEXT://192.168.50.4:9092,SSL://192.168.50.4:9093
Producer was started and is publishing using SSL interface. bin/kafka-console-producer.sh --broker-list 192.168.50.4:9093 --topic test-topic --producer.config config/producer-ssl.properties Old consumer is able to read from plain test interface bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test-topic --consumer.config config/consumer.properties --from-beginning --delete-consumer-offsets But the new consumer is not reading anything from both SSL and plain test ports. bin/kafka-console-consumer.sh --bootstrap-server 192.168.50.4:9093 --topic test-topic --new-consumer --consumer.config config/consumer-ssl.properties --from-beginning bin/kafka-console-consumer.sh --bootstrap-server 192.168.50.4:9092 --topic test-topic --new-consumer --consumer.config config/consumer.properties --from-beginning group.id=console-consumer-group & exclude.internal.topics=false are set in consumer properties For SSl, I've set these too security.protocol=SSL ssl.truststore.location=/path/to/client.truststore.jks ssl.truststore.password=**** Any suggestions on how to debug this? Srikanth