Hi Leonard,
Thank you so much! It worked, I did get a new error but it is unrelated to
this question.
Den man. 18. maj 2020 kl. 15.21 skrev Leonard Xu <xbjt...@gmail.com>:
> More precisely: Should the sink table `sql-sink` missed required version
> option.
>
>
> 在 2020年5月18日，21:13，Leonard Xu <xbjt...@gmail.com> 写道：
>
> Hi,
>
> Look likes you missed two required parameters: version and topic[1], you
> need to add them for both source table and sink table.
>
> .connect(
> new Kafka()
> .version("0.11") // required: valid connector versions are
> // "0.8", "0.9", "0.10", "0.11", and "universal"
> .topic("...") // required: topic name from which the table is read
>
>
> Best,
> Leonard Xu
> [1]
> https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/connect.html#kafka-connector
>
>
> 在 2020年5月18日，12:28，Martin Frank Hansen <m...@berlingskemedia.dk> 写道：
>
> connect(new Kafka()
> .version("universal")
>
>
>
>
--
Best regards
Martin Hansen
