Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- #Create consumer config
- echo "exclude.internal.topics=false" > /tmp/consumer.config
- #Consume all offsets
- ./kafka-console-consumer.sh --consumer.config /tmp/consumer.config \
- --formatter "kafka.coordinator.GroupMetadataManager\$OffsetsMessageFormatter" \
- --zookeeper localhost:2181 --topic __consumer_offsets --from-beginning
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement