Kafka tools related commands

kafka_message_check.sh

#List topics
kafka-topics --zookeeper zk01.example.com:2181 --list

#Get kafka offsets info from kafka internal topic with ssl configuration
#included formatter to translate binary data
kafka-console-consumer --bootstrap-server 10.180.48.138:19093 --topic __consumer_offsets \
                       --formatter "kafka.coordinator.group.GroupMetadataManager\$OffsetsMessageFormatter" \
                       --from-beginning --consumer-property bootstrap.servers=10.180.48.138:19093 \
                       --consumer-property security.protocol=SSL \
                       --consumer-property ssl.truststore.location=/etc/kafka/secrets/kafka.truststore.jks \
                       --consumer-property ssl.truststore.password=trus_pass
                       --consumer-property ssl.keystore.location=/etc/kafka/secrets/kafka.keystore.jks \
                       --consumer-property ssl.keystore.location=/etc/kafka/secrets/kafka.keystore.jks \
                       --consumer-property ssl.keystore.password=keystore_pass \
                       --consumer-property ssl.key.password=key_pass