@vvcephei yeah that makes sense. For Avro the `GenericRecord` type is similar to the untyped example here, while for `SpecificRecord` one can defines a `SpecificAvroSerde<T extends SpecificRecord> implements Serde<T>`, and the schema generated classes will have the form of `MyClass extends org.apache.avro.specific.SpecificRecordBase implements org.apache.avro.specific.SpecificRecord` (i.e. it is much more friendly than POJO) so it should be okay. For other types although I'm not very familiar either my guess would be some tricks like the one for Avro can be applied as well.
[ Full content available at: https://github.com/apache/kafka/pull/5590 ] This message was relayed via gitbox.apache.org for [email protected]
