华为kafka安全版重置group中的topic offset不生效问题

Posted 2023-03-13

参考技术A

华为kafka安全版，使用New Consumer API，采用group方式，消费者消费特定group下的topic数据，当group.id重置时，组中的所有topic就就会重头开始消费。如果只需要group中的某一个topic从头开始消费，而其他的topic接着上一次消费的位置继续消费，就不能简单的更换group.id来实现了。以下有两种方式可以用来重置offset (调整过程中必须保证消费者处于停止状态！！！)

以上操作完之后，正常情况下就可以执行命令1检查重置是否成功，当然笔者的情况是重置没有生效，执行操作1发现currentOffset依然没有变，于是就有了第二种方式 —— 使用consumer的java API

方式二使用的是消费者消费数据时提交的offset信息，一般来说只要topic可以正常被消费，方式二都能生效。