apache-kafka - Samza 的 OutgoingMessageEnvelope 是否需要用于 partitionKey 的 SerDe 以及如何指定它？

Question

与how-can-you-create-a-partition-on-a-kafka-topic-using-samza 类似，我需要构造一条消息来控制它如何通过使用 partitionKey 进行路由。key 和 message 确实需要 SerDe，但我不确定 partitionKey 是否也需要。如果是这样，配置语法是什么？我想我可以在内部使用 key 作为 partitionKey 来依赖 Samza，但我宁愿让它们明确和分开。

Answer 1

从源代码来看，分区键似乎不需要 SerDe - 注意键和消息具有相应的 xxxxSerializerName

public class OutgoingMessageEnvelope {
  private final SystemStream systemStream;
  private final String keySerializerName;
  private final String messageSerializerName;
  private final Object partitionKey;
  private final Object key;
  private final Object message;