Hi Team, How can I generate stream within another stream ? For Eg: I have a stream of data with Kafka as Source. For each event from Kafka I want to fetch data from database. Can I get the data from data base as a stream ? Transform the kafka stream into database stream based on the data I get in Kafka. Appreciate any help with this. Thanks

async i/o is probably what you want: https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/operators/asyncio/

Potentially relevant, if you want to use the JDBC connector for table look up and bounce it to a stream: https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/table/jdbc/#lookup-cache