1、同一个消费者组的话,修改了offset,那么共同生效(会受影响)。
2、根据时间维度的,0.9版本不行,是1.0之后才有。
3、seek
可以。
感谢回复。我看了下0.10.1版本的javadoc 这个里面的seek方法里有这么一句
Note that you may lose data if this API is arbitrarily used in the middle of consumption, to reset the fetch offsets
如何理解这个"arbitrarily"?如果使用您的代码传递的消费者组和正在使用的消费者组是同样的话 offset可能会被重置吗?换句话说,是否意味着我可以借由这个方法修改当前消费者组的偏移量?还是说 这个描述的仅针对正在被消费中的数据?
我在这个 https://www.orchome.com/35 页面下曾提过类似的问题,0.9.x的版本的javadoc里关于seek也是这么描述的。那实际上当初那个问题或许可以通过这个方式解决?
可以根据时间来重新消费这些数据。
参考:https://www.orchome.com/1004
0.9.0版本的Kafka的consumer-groups.sh没有可以修改偏移量的--reset-offsets选项。是否意味着这个版本下的topic无法修改偏移量了? :(