samza的outgoingmessageenvelope需要partitionkey的serde吗？如何指定它？

3npbholx 于 2021-06-08 发布在 Kafka

关注(0)|答案(1)|浏览(349)

类似于how-can-you-create-a-partition-on-a-kafka-topic-using-samza，我需要构造一个消息来控制如何使用partitionkey路由。键和消息确实需要serde，但我不确定partitionkey是否也需要serde。如果是，配置语法是什么？我想我可以在内部依赖samza，使用key作为partitionkey，但我更愿意让它们显式地分开。

apache-kafka apache-samza

来源：https://stackoverflow.com/questions/32891581/does-samzas-outgoingmessageenvelope-require-a-serde-for-partitionkey-and-how-do

1条答案

按热度按时间

yqhsw0fo1#

从源代码来看，分区键似乎不需要serde-note键，而消息具有相应的xserializername

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;

赞(0）回复(0）举报 2021-06-08

我来回答

samza的outgoingmessageenvelope需要partitionkey的serde吗？如何指定它？

1条答案

相关问题

热门标签

最新问答