Hi Kant,
You are right. It is not needed since Kafka 0.9+. We already have an issue
to make it optional.
https://issues.apache.org/jira/browse/FLINK-16125
Best,
Jark
On Tue, 3 Mar 2020 at 20:17, kant kodali wrote:
> Hi All,
>
> The zookeeper.connect is not needed for KafkaConsumer or KafkaAdmi
Hi All,
The zookeeper.connect is not needed for KafkaConsumer or KafkaAdminClient
however Flink requires it. You can also see in the Flink TaskManager logs
the KafkaConsumer is not recognizing this property anyways.
bsTableEnv.connect(
new Kafka()
.property("bootstrap.servers", "local
