Skip to content

Instantly share code, notes, and snippets.

@conorfennell

conorfennell/consume.sh

Created June 27, 2018 20:13
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save conorfennell/ca6b41b53a10fe9a0895f2bed0991758 to your computer and use it in GitHub Desktop.
Save conorfennell/ca6b41b53a10fe9a0895f2bed0991758 to your computer and use it in GitHub Desktop.
Download ZIP
consume private __consumer_offsets
Raw
consume.sh
echo "exclude.internal.topics=false" > /tmp/consumer.config
#Only consume the latest consumer offsets
./kafka-console-consumer.sh --consumer.config /tmp/consumer.config \
--formatter "kafka.coordinator.group.GroupMetadataManager\$OffsetsMessageFormatter" \
--bootstrap-server ${BOOTSTRAP_SERVER} --topic __consumer_offsets
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment