apache-kafka - flink出力をkafkaにスロットルするには?

Question

100 messages/secondストリームから kafka トピックに送信したいと考えています。そうするのに十分な量のデータがストリームにあります。

これまでのところ、ウィンドウの概念を見つけましたが、ユース ケースに合わせて変更することはできません。

Answer 1

で簡単にこれを行うことができますProcessFunction。カウンターを Flink 状態に保ち、カウンターが 100 未満の場合にのみ要素を放出します。その間、タイマーを使用してカウンターを 1 秒に 1 回ゼロにリセットします。