是否呼吁寻求一个组中的消费者为整个集团

问题描述：

偏移我有3名消费者在同一组，我打电话寻求（）来设置一个消费者一个分区的偏移量。会为组中的所有使用者设置偏移量还是仅为该特定分区上的偏移量设置偏移量？是否呼吁寻求一个组中的消费者为整个集团

我希望能够重置组与日志中的所有记录的开始。但我只会呼吁寻求一位消费者。

答

具有3名消费者在同一组是指一个分区只分配给这些消费者之一，所以当你打电话寻求，它只有该分区上只有一个消费者，以便其他人不产生影响影响。

答

寻求（）将回滚到仅该分区指定的偏移量。但是，对于旧的高级消费者API，没有办法做到这一点。但在调用方法

public void seek(TopicPartition partition, 
    long offset);

将快倒在分区提供TopicPartition的话题来抵消。

如果你想重置集团消费，那么你就必须做出寻求电话TopicPartition与每个分区的偏移。

或者你可以使用offsetsForTimes并按规定在这里呼吁组分区： https://jeqo.github.io/post/2017-01-31-kafka-rewind-consumers-offset/

如果您使用的是旧的高层次的消费，目前还没有API中的消费者复位偏移。唯一的方法是停止所有消费者并手动为ZK重置该消费群组的偏移量。

然而，在0.11.0版本中加入一个工具来重置偏移量与不同的范围如主题，分区等群体。您可以在这里找到详细信息： https://cwiki.apache.org/confluence/display/KAFKA/KIP-122%3A+Add+Reset+Consumer+Group+Offsets+tooling。和 https://issues.apache.org/jira/browse/KAFKA-4743