You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Lakshmi Manasa Gaduputi (Jira)" <ji...@apache.org> on 2021/04/09 01:32:00 UTC

[jira] [Created] (SAMZA-2646) Minor refactor of StreamAppender to support sending formats other than byte[] to SystemProducer

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)