Re: FlinkKafkaProducer API

2016-06-09 Thread Fabian Hueske
Great, thank you! 2016-06-09 17:38 GMT+02:00 Elias Levy : > > On Thu, Jun 9, 2016 at 5:16 AM, Fabian Hueske wrote: > >> thanks for your feedback. I think those are good observations and >> suggestions to improve the Kafka producers. >> The best

Re: FlinkKafkaProducer API

2016-06-09 Thread Elias Levy
On Thu, Jun 9, 2016 at 5:16 AM, Fabian Hueske wrote: > thanks for your feedback. I think those are good observations and > suggestions to improve the Kafka producers. > The best place to discuss such improvements is the dev mailing list. > > Would like to repost your mail

Re: FlinkKafkaProducer API

2016-06-09 Thread Fabian Hueske
? Thanks, Fabian 2016-06-09 3:58 GMT+02:00 Elias Levy <fearsome.lucid...@gmail.com>: > The FlinkKafkaProducer API seems more difficult to use than it should be. > > The API requires you pass it a SerializationSchema or a > KeyedSerializationSchema, but the Kafka pr

FlinkKafkaProducer API

2016-06-08 Thread Elias Levy
The FlinkKafkaProducer API seems more difficult to use than it should be. The API requires you pass it a SerializationSchema or a KeyedSerializationSchema, but the Kafka producer already has a serialization API. Requiring a serializer in the Flink API precludes the use of the Kafka serializers