TOP

kafka手动修改消费者偏移量
2019-01-18 02:32:14 】 浏览:1532
Tags:kafka 手动 修改 消费者

1.建立一个测试主题:

[root@snn bin]#./kafka-topics.sh --zookeeper snn:2181 --topic offset-test --partitions 2 --replication-factor 2 –create

检查主题的设置情况:

[root@snn bin]#./kafka-topics.sh --zookeeper snn:2181 --topic offset-test –describe

2.向主题中写入数据

[root@snn bin]# ./kafka-console-producer.sh --broker-list snn:6667 --topic offset-test

3.消费主题

[root@snn bin]# ./kafka-console-consumer.sh --bootstrap-server snn:6667 --group offsettest --topic offset-test –from-beginning

4.查看消费者消费偏移量

[root@snn bin]#./kafka-consumer-groups.sh --bootstrap-server snn:6667 --group offsettest –describe

5.设置为最初偏移量:

[root@snn bin]#./kafka-consumer-groups.sh --bootstrap-server snn:6667 --group offsettest --topic offset-test --reset-offsets --to-earliest –execute

重新读取数据:

6.设置任意偏移量:

[root@snn bin]# ./kafka-consumer-groups.sh --bootstrap-server snn:6667 --group offsettest --topic offset-test --reset-offsets --to-offset 3 –execute

7.设置最近偏移量

[root@snn bin]# ./kafka-consumer-groups.sh --bootstrap-server snn:6667 --group offsettest --topic offset-test --reset-offsets --to-latest --execute

参考文章:https://www.cnblogs.com/felixzh/p/8028118.html


kafka手动修改消费者偏移量 https://www.cppentry.com/bencandy.php?fid=120&id=204015

】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇docker   kafka 启动 下一篇对接 kafka的 spark程序   ..