Getting ClassCast Exception : GenericData$Record cannot be cast to org.apache.avro.specific.SpecificRecordBase

[ghost]

While using the given AvroSerializer and Deserializer in Serde with Kafka streams , I am facing ClassCastException GenericData$Record cannot be cast to org.apache.avro.specific.SpecificRecordBase.

config.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, Serdes.serdeFrom(new AvroSerializer<MemberMeasureKey>() , new AvroDeserializer<MemberMeasureKey>(MemberMeasureKey.class)).getClass()); config.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, Serdes.serdeFrom(new AvroSerializer<MemberMeasureValue>() , new AvroDeserializer<MemberMeasureValue>(MemberMeasureValue.class)).getClass());

Please help me on this.

[ShiyangHuang]

Same Issue