Lakshmi Manasa Gaduputi created SAMZA-2627:
----------------------------------------------
Summary: Make StreamAppender extensible for sending messages to
SystemProducer
Key: SAMZA-2627
URL: https://issues.apache.org/jira/browse/SAMZA-2627
Project: Samza
Issue Type: Improvement
Reporter: Lakshmi Manasa Gaduputi
Assignee: Lakshmi Manasa Gaduputi
StreamAppender currently sends to the underlying SystemProducer the logEvents
as OutgoingMessageEnvelope(systemStream, keyBytes = containerName,
serializedMessage). This corresponds to the OME with both partition key and
record key set to keyBytes.
This ticket is to provide classes extending StreamAppender with higher control
over the partition and record keys in the OME.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
