From c66c01aa72ab987360c6d44d3ecffb2bf56a7153 Mon Sep 17 00:00:00 2001 From: IbrahimBagalwa Date: Tue, 7 Nov 2023 14:04:06 +0200 Subject: [PATCH] fix: docs Autodetect for schemas --- docs/userguide/models.rst | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/docs/userguide/models.rst b/docs/userguide/models.rst index 7945764df..5831a74b5 100644 --- a/docs/userguide/models.rst +++ b/docs/userguide/models.rst @@ -186,13 +186,13 @@ a schema that reads message key and value type from Kafka headers: serializer=None): if loads is None: loads = app.serializers.loads_value - # try to get key_type and serializer from Kafka headers + # try to get value_type and serializer from Kafka headers headers = dict(message.headers) value_type_name = headers.get('ValueType') serializer = serializer or headers.get('ValueSerializer') if value_type_name: - value_type = registry[value_type] - return loads(value_type, message.key, + value_type = registry[value_type_name] + return loads(value_type, message.value, serializer=serializer) else: return super().loads_value(