Hi,

 

Recently I have found that in the Flink Kafka Connector, the parameter
"connector.properties.zookeeper.connect" is made mandatory for users.
Therefore without it, Flink would throw an exception saying "Caused by:
org.apache.flink.table.api.ValidationException: Could not find required
property 'connector.properties.zookeeper.connect'".

 

However, as far as I know, for Kafka versions that are currently supported
by the universal connector, this setting is not mandatory anymore. Here I
would like know if this parameter could be changed to optional, and what are
the negative impacts if doing so?

 



 

Thanks : )

 

Sincerely,

Weike

Reply via email to