Аналогично how- can-you-create-a-partition-on-a-kafka-topic-using-samza Мне нужно создать сообщение, контролирующее его маршрутизацию с помощью partitionKey. для ключа и сообщения требуется SerDe, но я не уверен, что и partitionKey тоже. Если да, то каков синтаксис конфигурации? Я полагаю, что могу положиться на Samza, используя внутри себя ключ как partitionKey, но я бы предпочел, чтобы они были явными и отдельными.
Требует ли Samza OutgoingMessageEnvelope SerDe для partitionKey и как его указать?
Ответы (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;
person
Edi Bice
schedule
20.10.2015
У меня есть связанный с этим вопрос, пожалуйста, не могли бы вы взглянуть? stackoverflow.com/ вопросы/33502397/
- person John; 03.11.2015
Только что сделал, и ответ Лукаса точен.
- person Edi Bice; 17.11.2015
