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
<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 <[email protected]> 写道：
>
> connect(new Kafka()
> .version("universal")
