ストリーム データを生成しようとしています。これは、整数型の 2 つの値を別の時間範囲でタイムスタンプと共に受け取り、Kafka をコネクタとして受け取る状況をシミュレートしようとしています。
Flink 環境をコンシューマーとして使用していますが、プロデューサーにとって最適なソリューションがどれかわかりません。(可能であれば、Java 構文は Scala より優れています)
Kafka から直接データを生成する必要がありますか? はいの場合、それを行うための最良の方法は何ですか? それとも、プロデューサーとして Flink からデータを生成し、それを Kafka に送信し、最後に Flink で再度使用する方が良いでしょうか? どうすればフリンクからそれを行うことができますか? または、ストリーム データを生成して Kafka に渡す別の簡単な方法があるかもしれません。
はいの場合は、それを達成するための軌道に乗せてください。