Re: FlinkKafkaProducer and Confluent Schema Registry

Dawid, Is there a projected date to deliver ConfluentRegistryAvroSerializationSchema ? thank you, Olga From: Dawid Wysakowicz Sent: Monday, October 22, 2018 10:40 AM To: trebl...@hotmail.com Cc: user Subject: Re: FlinkKafkaProducer and Confluent Schema Registry

Re: FlinkKafkaProducer and Confluent Schema Registry

e to > deliver ConfluentRegistryAvroSerializationSchema ? > > thank you, > Olga > > > *From:* Dawid Wysakowicz > *Sent:* Monday, October 22, 2018 10:40 AM > *To:* trebl...@hotmail.com > *Cc:* user > *Subjec

Re: FlinkKafkaProducer and Confluent Schema Registry

Hi Olga, There is an open PR[1] that has some in-progress work on corresponding AvroSerializationSchema, you can have a look at it. The bigger issue there is that SerializationSchema does not have access to event's key so using topic pattern might be problematic. Best, Dawid [1] https://github.com

Re: FlinkKafkaProducer and Confluent Schema Registry

Hi Olga, Sorry for the late reply. I think that Gordon (cc’ed) could be able to answer your question. Cheers, Kostas > On Oct 13, 2018, at 3:10 PM, Olga Luganska wrote: > > Any suggestions? > > Thank you > > Sent from my iPhone > > On Oct 9, 2018, at 9:28 PM, Olga Luganska

Re: FlinkKafkaProducer and Confluent Schema Registry

Any suggestions? Thank you Sent from my iPhone On Oct 9, 2018, at 9:28 PM, Olga Luganska mailto:trebl...@hotmail.com>> wrote: Hello, I would like to use Confluent Schema Registry in my streaming job. I was able to make it work with the help of generic Kafka producer and FlinkKafkaConsumer wh