Hi,
What is the best way to use Confluent SchemaRegistry with FlinkKafkaProducer? What I have right now is as follows. SerializationSchema<GenericRecord> serializationSchema = |
Hi Anil, Here's a pointer to Flink's end-2-end test that's checking the integration with schema registry [1]. It was recently updated so I hope it works the same way in Flink 1.9. Best, Fabian Am Sa., 18. Apr. 2020 um 19:17 Uhr schrieb Anil K <[hidden email]>:
|
Thanks Fabian, I ended up using something like below. public class GenericSerializer implements KafkaSerializationSchema<GenericRecord> { Then used a new object of GenericSerializer in the FlinkKafkaProducerFlinkKafkaProducer<GenericRecord> producer = On Tue, Apr 21, 2020 at 3:34 AM Fabian Hueske <[hidden email]> wrote:
|
Thanks for sharing your solution Anil! Cheers, Fabian Am Di., 21. Apr. 2020 um 09:35 Uhr schrieb Anil K <[hidden email]>:
|
Free forum by Nabble | Edit this page |