lakshmi-manasa-g opened a new pull request #1488: URL: https://github.com/apache/samza/pull/1488
Issue: StreamAppender is restrictive in explicitly using byte[] for the serialized log event in the OutgoingMessageEnvelope(OME) sent to underlying SystemProducer. This restricts how the classes extending StreamAppender send to SystemProducer as it prevents sending objects (like avro records) to OME. Change: Introduce a protected interface to hold the encoded log event and a private impl of it for streamappender. Tests: existing tests pass, no functionality change. API changes: none Usage, upgrade instructions: none -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
