async def METHOD_NAME(producer):
    # Specifying partition_id.
    event_data_batch_with_partition_id = await producer.create_batch(partition_id='0')
    event_data_batch_with_partition_id.add(EventData('Message will be sent to target-id partition'))
    await producer.send_batch(event_data_batch_with_partition_id)