flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Martin Frank Hansen <m...@berlingskemedia.dk>
Subject Re: Help with table-factory for SQL
Date Tue, 19 May 2020 05:35:11 GMT
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 <xbjtdcq@gmail.com>:

> More precisely:  Should the sink table `sql-sink` missed required version
> option.
>
>
> 在 2020年5月18日,21:13,Leonard Xu <xbjtdcq@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 <mafh@berlingskemedia.dk> 写道:
>
> connect(new Kafka()
>       .version("universal")
>
>
>
>

-- 

Best regards
Martin Hansen

Mime
View raw message