Kafka Utils

Getting message from speific offset
./bin/kafka-console-consumer.sh --bootstrap-server kafka-broker.service-pe-test.consul.c-test.ost.cloud.internal:9093 --max-messages 1 --group basan_PERF_console --consumer.config config-stage.properties --partition 1 --offset 14677669 --topic order-demand



config-stage.properties
ssl.truststore.location=/Users/basan/Documents/workspace-sts-3.8.4.RELEASE/ds-conumption-spring/ssl-config/prod/client.truststore.jks
ssl.truststore.password=**********
ssl.keystore.location=/Users/basan/Documents/workspace-sts-3.8.4.RELEASE/ds-conumption-spring/ssl-config/stg/ds-stg.target.com.jks
ssl.keystore.password=**********
security.protocol=SSL
ssl.protocol=TLSv1.2



Get lag for a specific consumner group

./bin/kafka-consumer-groups.sh --bootstrap-server kafka-broker.service-pe-test.consul.c-test.ost.cloud.internal:9093 --group OPROD12CV1_SHIPMENT_HEADER --describe --command-config config-stage.properties