Advertisement
josephxsxn

readFromKafkaconsumeroffsets

Jun 9th, 2020
684
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Bash 0.33 KB | None | 0 0
  1. #Create consumer config
  2. echo "exclude.internal.topics=false" > /tmp/consumer.config
  3. #Consume all offsets
  4. ./kafka-console-consumer.sh --consumer.config /tmp/consumer.config \
  5. --formatter "kafka.coordinator.group.GroupMetadataManager\$OffsetsMessageFormatter" \
  6. --bootstrap-server localhost:9092 --topic __consumer_offsets --from-beginning
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement