OneCricketeer/confluent-avro-get-schema-id.sh

Created January 30, 2018 23:44

Star () You must be signed in to star a gist
Fork () You must be signed in to fork a gist

Learn more about clone URLs
Clone this repository at <script src="https://gist.github.com/OneCricketeer/d9179fc010ffa4bf33cf30dd3db29ee0.js"></script>
Save OneCricketeer/d9179fc010ffa4bf33cf30dd3db29ee0 to your computer and use it in GitHub Desktop.

Download ZIP

Get the embedded schema IDs of Confluent KafkaAvroSerializer

Raw

confluent-avro-get-schema-id.sh

while :; do kafka-console-consumer --topic $TOPIC --bootstrap-server $KAFKA --max-messages=1 2>/dev/null | hexdump | head -n 1 | cut -d' ' -f 5,6 | tr -ds '[[:space:]]' '' | { IFS= read -r schemaId; printf '%s\n' "$((16#${schemaId}))"; }; done

Author

OneCricketeer commented Jan 30, 2018 •

edited

Loading

Expanded version

while :; 
do 
  kafka-console-consumer --topic $TOPIC --bootstrap-server $KAFKA --max-messages=1 2>/dev/null \
    | hexdump | head -n 1 \
    | cut -d' ' -f 5,6 | tr -ds '[[:space:]]' '' \
    | { IFS= read -r schemaId; printf '%s\n' "$((16#${schemaId}))"; }; 
done

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment