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

版权声明：本文来源CSDN，感谢博主原创文章，遵循 CC 4.0 by-sa 版权协议，转载请附上原文出处链接和本声明。
原文链接：https://blog.csdn.net/only_1/article/details/83753109
站方申明：本站部分内容来自社区用户分享，若涉及侵权，请联系站方删除。

发表于 2020-03-06 22:55:53
阅读 ( 1344 )
分类：

kafka手动修改消费者偏移量

你可能感兴趣的文章

精选的优质文章

0 条评论

官方社群

GO教程

推荐文章

猜你喜欢

随便看看