SCDFストリームを再展開する際のカフカオフセットの変化量はどのくらいですか？

Question

私はとKafka 0.10.0をストリームアプリケーションに使用します。

ストリームをアンデプロイしてからもう一度デプロイすると、現在のカフカトピックのオフセットになる場合がありますが、最も古いオフセットから開始することがあります。

ストリームの再デプロイ時に予測可能な動作（現在のオフセット、最新のオフセット、最も古いオフセットなど）を取得するよう設定することはできますか。

ストリームごとに異なる動作が期待できる方法はありますか？

Answer 1

ストリームを再デプロイするときは、spring.cloud.stream.kafka.bindings.<channelName>.consumer.startOffset〜latestを使用する必要があります。デフォルトの動作はearliestです。詳細はthisのドキュメントをご覧ください。