REST API を公開するだけの一連の怠惰なコンシューマーに代わってメッセージをコンシュームする必要があります。したがって、Kafka トピックからメッセージをフェッチし、公開された API で HTTP POST 操作を行うシンク コネクタを用意する予定です。
考慮すべき重要な要素の 1 つはスロットリングです。API の層 SLA を満たすためにシンク タスクを調整するために、どのメカニズムを提案しますか。Kafka にはクライアント クォータ機能があることは理解していますが、クライアント クォータを動的に調整できる API リクエスト/分または秒を追跡する最適なメカニズムは何ですか?