Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- ./kafka-consumer-groups.sh --bootstrap-server kafka-hk-02-public.streetside.io:9092 --reset-offsets --to-latest --group weibo_prod_transfer_comments01 --topic sina.firehose.comments.in --execute
- ./kafka-consumer-groups.sh --bootstrap-server kafkaprod01:9092 \
- --topic vk.likes:0 \
- --reset-offsets \
- --to-offset 621057649 \
- --execute \
- --group OPS-VK-FireHose-Prod-1
- ./kafka-consumer-groups.sh --bootstrap-server kafkaprod11.boardreader.com:9092 \
- --all-topics \
- --reset-offsets \
- --to-latest \
- --execute \
- --group OPS_PROD_NIFI_SINA02
- ###This command prints the old offsets out of zookeeper
- ##Notice it uses --zookeeper and not --bootstrap-server
- ##be warned this lists the offsets for ALL topics for this group and not just the topic we want.
- ./kafka-consumer-groups.sh --zookeeper localhost:2181 --group igortestdedup --describe
- ##This command sets the offset for the new client used after Kafka 0.10.
- ## Notice the topic value is STRING:INTEGER String being the topic name, integer being the partition we are changing.
- ## --to-offset is the offset we want to switch it to.
- ./kafka-consumer-groups.sh --bootstrap-server kafkaprod01:9092 --topic disqus.fullfeed.in:6 --reset-offsets --to-offset 29500147 --execute --group igortestdedup
- ./kafka-consumer-groups.sh --bootstrap-server kafkaprod12:9092 --topic sina.firehose.out:9 --reset-offsets --to-offset 1195984633 --execute --group sina-manticore-pq
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement