0

Kafka キューからいくつかのメッセージを消費しましたが、もう一度それらを消費したいと思います (すべてのデータを最初からフェッチするだけです)。Scala またはKafka Rest Proxyを使用してオフセットをリセットするにはどうすればよいですか? 私は現在使用してい"auto.offset.reset": "smallest"ます：

curl -X POST -H "Content-Type: application/vnd.kafka.v1+json" \
      --data '{"format": "json", "auto.offset.reset": "smallest"}' \
      XXX.XX.XXX.XXX:9092/consumers/test

私は解決策に興味がないことに注意してください

4

1 に答える 1

1

URL の最後のパラメーターはgroup Idです。Kafka は、グループ ID ごとにコミットされたオフセットを保存します。したがって、グループ ID を変更するだけで十分です (.../consumers/newGroupId)。

于 2017-01-04T17:18:11.977 に答える