async def METHOD_NAME(encoder, event_data):
    # encoder.decode would extract the schema id from the content_type,
    # retrieve schema from Schema Registry and cache the schema locally.
    # If the schema id is in the local cache, the call won't trigger a service call.
    decoded_content = await encoder.decode(event_data)
    print("Decoded content is: ", decoded_content)
    return decoded_content