Hi, You can do this directly via the SQL client by defining (for example Kafka) as a TABLE [1] and using an INSERT INTO [2].
Best regards, Martijn [1] https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/connectors/table/kafka/ [2] https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/sql/insert/ On Wed, 15 Sept 2021 at 17:00, Pedro Silva <pedro.cl...@gmail.com> wrote: > Hello, > > Is it possible to configure a sink for sql client queries other than the > terminal/stdout? > Looking at the SQL Client Configuration > <https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/table/sqlclient/#sql-client-configuration>, > it seems that the output of the client is always to visualize the results. > > If I wanted to sink a changelog stream to a database like Postgres or > Kafka topic would I have to create a streaming application, hardcode the > SQL query and configure the sink as java/scala/python code? > > Thank you. >
