Hi,

We have a usecase to read data from Kafka serialized with
KafkaAvroSerializer and schema is present in Schema Registry.

When we are trying to use ValueDeserializer as
io.confluent.kafka.serializers.KafkaAvroDeserializer to get GenericRecord,
we are seeing errors.

Does KafkaIO.read() supports reading from schema registry and using
confluent KafkaAvroSerDe?

Regards,
Rahul

Reply via email to