async def METHOD_NAME(encoder: JsonSchemaEncoder, schema_id: str):
    dict_content_ben = {"name": "Ben", "favorite_number": 7, "favorite_color": "red"}
    dict_content_alice = {"name": "Alice", "favorite_number": 15, "favorite_color": "green"}
    # Schema would be automatically registered into Schema Registry and cached locally.
    event_data_ben = await encoder.encode(
        dict_content_ben, schema_id=schema_id, message_type=EventData
    )
    # The second call won't trigger a service call.
    event_data_alice = await encoder.encode(
        dict_content_alice, schema_id=schema_id, message_type=EventData
    )
    print("Encoded content is: ", next(cast(Iterator[bytes], event_data_ben.body)))
    print("Encoded content is: ", next(cast(Iterator[bytes], event_data_alice.body)))
    print("Encoded content type is: ", event_data_ben.content_type)
    print("Encoded content type is: ", event_data_alice.content_type)
    return [event_data_ben, event_data_alice]