如果您使用samza的outgoingmessageenvelope使用以下格式发送消息：

public OutgoingMessageEnvelope(SystemStream systemStream,
                               java.lang.Object partitionKey,
                               java.lang.Object key,
                               java.lang.Object message)
Constructs a new OutgoingMessageEnvelope from specified components.
Parameters:
systemStream - Object representing the appropriate stream of which this envelope will be sent on.
partitionKey - A key representing which partition of the systemStream to send this envelope on.
key - A deserialized key to be used for the message.
message - A deserialized message to be sent in this envelope.

如果在流任务的process（）方法中调用这个方法，并希望将传入的消息路由到适当的分区，那么samza会在调用该方法时为您创建分区吗？
例如

MessageA = {"id": "idA", "key": "keyA", "body":"some details"}
MessageB = {"id": "idB", "key": "keyB", "body":"some more details"}

如果我在流任务的 process() 哪里 msg 是消息示例：

public void process(IncomingMessageEnvelope envelope, MessageCollector collector, TaskCoordinator coordinator) {
    // ...
    String partition = msg["id"]
    String key = msg["key"]
    collector.send(new OutgoingMessageEnvelope(new SystemStream("kafka", "PartitionedMessages"), id, key, msg));
    // ...

这是否会自动为我创建分区ida和idb（即，在向它们发送消息之前，我是否需要创建这些分区）？我希望能够将消息路由到适当的分区，并且能够使用单独的消息密钥进行日志压缩。