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 place to discuss such improvements is the dev maili

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 there or open JIRAs wher

Re: FlinkKafkaProducer API

2016-06-09 Thread Fabian Hueske
? Thanks, Fabian 2016-06-09 3:58 GMT+02:00 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 AP

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