but RMQ is not listed in the supported Taple API connectors, should I define a custom source?
On Mon, Aug 23, 2021 at 4:56 AM Caizhi Weng <tsreape...@gmail.com> wrote: > 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 >> >
