Hey everyone,

I'm currently rewriting the KafkaTabeSinkTest and discovered something that doesn't seem to be intended: Is it intended that FlinkKafkaProducer08 cannot be instantiated without a running Kafka instance?

The constructor of FlinkKafkaProducerBase calls getKafkaProducer() which actually should be called in the open() method first. What happens if the Client has no access to the Kafka properties (e.g. using an remote execution environment)? Then it is impossible to create a KafkaProducer?

Thanks.

Timo

Reply via email to