async def METHOD_NAME():
    schema_registry = SchemaRegistryClient(
        fully_qualified_namespace=SCHEMAREGISTRY_FULLY_QUALIFIED_NAMESPACE,
        credential=token_credential,
    )
    encoder = AvroEncoder(
        client=schema_registry, group_name=GROUP_NAME, auto_register=True
    )
    event_data = await encode_message_content_dict(encoder)
    decoded_content = await decode_with_content_and_content_type(encoder, event_data)
    await encoder.close()
    await token_credential.close()