Samza的OutgoingMessageEnvelope是否需要一個SerDe for partitionKey，以及如何指定它？

Question

與how-can-you-create-a-partition-on-a-kafka-topic-using-samza類似，我需要構造一個消息來控制如何通過使用partitionKey路由它。密鑰和消息確實需要SerDe，但我不確定partitionKey是否也可以。如果是這樣，配置語法是什麼？我想我可以依靠Samza內部使用key作爲partitionKey，但我寧願讓它們明確和分開。

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;