You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Srikanth <sr...@gmail.com> on 2016/08/10 14:30:40 UTC

Console consumer with SSL

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