apache-kafka-connect

1熱

1答えて

Kafkaを拡張してSinkTaskを接続し、指定されたオフセットから消費を開始してください

SinkTaskを拡張して自分自身のシンクコネクタを作成したいと考えています。フラッシュ中にオフセットを保存し、次にシンクコネクタを開始したときに、保存されたオフセットから読み込みを再開するには、正しい方法はありますか？私は自分自身のオフセット割り当てるためにオーバーライドinitialize(SinkTaskContext context)のSinkTaskContextを使用してみました：