Lakshmi Manasa Gaduputi created SAMZA-2646:
----------------------------------------------
Summary: Minor refactor of StreamAppender to support sending
formats other than byte[] to SystemProducer
Key: SAMZA-2646
URL: https://issues.apache.org/jira/browse/SAMZA-2646
Project: Samza
Issue Type: Improvement
Reporter: Lakshmi Manasa Gaduputi
Assignee: Lakshmi Manasa Gaduputi
StreamAppender currently sends only byte[] to the SystemProducer and a class
extending StreamAppender is forced to send out only byte[]. A Samza
SystemProducer takes in OutgoingMessageEnvelope which can take any object incl
byte[]. This ticket is to do a small refactor of the part of StreamAppender
dealing with the encoded log event as byte[].
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
