put()Kafka Connect Sink タスクのメソッドがトリガーされる間隔を制御できますか? この点で、Kafka Connect フレームワークの予想される動作は何ですか? 理想的には、たとえば、「X 件の新しいレコード/Y 件の新しいバイトがない限り、または最後の呼び出しから Z ミリ秒経過していない限り、私に電話しないでください」と指定したいと思います。これにより、シンク タスク内のバッチ処理ロジックがより単純になる可能性があります (ドキュメントを引用すると、「多くの場合、内部バッファリングが役立つため、レコードのバッチ全体を一度に送信できるため、ダウンストリーム データ ストアにイベントを挿入するオーバーヘッドが削減されます) 。 .
質問する
925 次