小编Hir*_*ala的帖子

我们需要开发一个代码，让消费者在运行时侦听特定的kafka生产者，然后在同一函数中产生从当前消耗的数据到另一个生产者主题的已处理数据。

这是为了将代码与Java集成在一起，使Java将代码链接到Java，在Java中Java生成到一个主题的消息，而Flink使用它并为另一个主题生成新数据，以供Java进一步处理。

请让我们知道是否还有另一种方法可以执行此过程。