Hi! You can first use the Table & SQL API to create a RMQ source table[1].
Then you can use the to_data_stream method in TableEnvironment to change the table to a data stream. [1] https://ci.apache.org/projects/flink/flink-docs-stable/docs/dev/python/table/python_table_api_connectors/ Nadia Mostafa <nadia.mostafa16...@gmail.com> 于2021年8月22日周日 下午11:57写道： > Hello, > > Is there any way to use RMQ as a data source in the DataStream python api? > > Thanks in advance >
