diff --git a/avro-serde/src/main/java/io/confluent/kafka/streams/serdes/avro/SpecificAvroSerde.java b/avro-serde/src/main/java/io/confluent/kafka/streams/serdes/avro/SpecificAvroSerde.java index 9964320db35..c0438cc1be9 100644 --- a/avro-serde/src/main/java/io/confluent/kafka/streams/serdes/avro/SpecificAvroSerde.java +++ b/avro-serde/src/main/java/io/confluent/kafka/streams/serdes/avro/SpecificAvroSerde.java @@ -102,6 +102,9 @@ public Deserializer deserializer() { return inner.deserializer(); } + /** + * WARNING: Only call this method once as only first call is used. + */ @Override public void configure(final Map serdeConfig, final boolean isSerdeForRecordKeys) { inner.serializer().configure(serdeConfig, isSerdeForRecordKeys);