This is possibly more of a Confluent question as GenericAvroSerde is in
Confluent example code base.

I have a small Stream application, which creates a KTable with String key
and GenericRecord value.

I then specify a Serde<GenericRecord> (new GenericAvroSerde) as value
deserializer when outputting to topic via table.to method.

I get a NPE on deserializing with this.schemaRegistry being null within
AbstractKafkaAvroSerializer#serializeImpl.

Could it be simply that GenericRecords are more of an intermediate class
and are not meant to be serialised?

I'd like to stream the values on topic as GenericRecord. I thought it
should work. Alternatively, guidance on using SpecificAvroSerde would be
very helpful.

Reply via email to