我创造了一个 Flink 使用flink消费者和生产者概念的应用程序/工作。
现在我还有一个要求，我需要创建一个 Producer 将数据发布到 topic 消耗在上面 Flink 应用程序。我创造了这个 Producer 应用程序使用 KafkaProducer &它正在按预期工作。但我也要做这个 Producer 应用程序为 Flink 工作。我在谷歌搜索，我无法找到创建一个详细信息 Flink 仅适用于生产商。
我创造了一个 Flink 使用flink消费者和生产者概念的应用程序/工作。
现在我还有一个要求，我需要创建一个 Producer 将数据发布到 topic 消耗在上面 Flink 应用程序。我创造了这个 Producer 应用程序使用 KafkaProducer &它正在按预期工作。但我也要做这个 Producer 应用程序为 Flink 工作。我在谷歌搜索，我无法找到创建一个详细信息 Flink 仅适用于生产商。
1条答案
按热度按时间eiee3dmh1#
每个flink作业都需要至少有一个源和一个汇。然而，您计划将数据写入生产者，使用一个可用的源来读取或生成它，或者实现您自己的。
数据从何而来？