flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timo Walther <twal...@apache.org>
Subject KafkaProducer can not be instantiated
Date Wed, 05 Oct 2016 14:51:02 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message