apache-kafka - KafkaConsumer の利用可能な最も古いメッセージに巻き戻す際の問題

Question

次のコードで、グループ G1 の 1 つの Kafka コンシューマのフェッチ オフセットを off1 に巻き戻しました。

  consumer1.set_topic_partitions((topic, partition, off1))

上記の行で、off1 は、対応するパーティション内のトピックで使用可能な最も古いメッセージのオフセットです。

今、次のように別のグループ G2 で Kafka コンシューマーをインスタンス化しています。

 consumer2 = KafkaConsumer(bootstrap_servers=broker,
                                  auto_offset_reset='smallest',
                                  auto_commit_enable=True,
                                  auto_commit_interval_ms=3000,
                                  group_id='G2'
                                  )

ここでは、フェッチ オフセットを off1 として読み取っています。これは、グループ G1 の consumer1 に対してリセットしたものと同じです。異なるグループのオフセットは異なるはずなので、それは起こらないはずだと思います。誰かが明らかにしたら、私は本当に感謝します. 前もって感謝します。