You can set key/value deserializers : https://github.com/apache/beam/blob/master/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java#L101 What are the errors you see?
Also note that Beam includes AvroCoder for handling Avro records in Beam. On Thu, Sep 27, 2018 at 6:05 AM rahul patwari <[email protected]> wrote: > 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 >
