[samza] branch master updated: SAMZA-2627: Make StreamAppender extensible for sending messages to SystemProducer (#1470)

[bharathkk]

This is an automated email from the ASF dual-hosted git repository.

bharathkk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git


The following commit(s) were added to refs/heads/master by this push:
     new 93c41df  SAMZA-2627: Make StreamAppender extensible for sending 
messages to SystemProducer (#1470)
93c41df is described below

commit 93c41dfbc776a1b0b24a947234d6d94981709a0e
Author: lakshmi-manasa-g <mgadup...@linkedin.com>
AuthorDate: Wed Mar 3 12:52:05 2021 -0800

    SAMZA-2627: Make StreamAppender extensible for sending messages to 
SystemProducer (#1470)
    
    Issue: StreamAppender sets both partition key and record key = container 
name for OutgoingMessageEnvelope sent to underlying SystemProducer. This 
restricts how the classes extending StreamAppender send to SystemProducer.
    
    Change: Mark sendEventToSystemProducer as protected.
---
 .../src/main/java/org/apache/samza/logging/log4j2/StreamAppender.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/StreamAppender.java
 
b/samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/StreamAppender.java
index bfba754..cadf63c 100644
--- 
a/samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/StreamAppender.java
+++ 
b/samza-log4j2/src/main/java/org/apache/samza/logging/log4j2/StreamAppender.java
@@ -439,7 +439,7 @@ public class StreamAppender extends AbstractAppender {
    * Helper method to send a serialized log-event to the systemProducer, and 
increment respective methods.
    * @param serializedLogEvent
    */
-  private void sendEventToSystemProducer(byte[] serializedLogEvent) {
+  protected void sendEventToSystemProducer(byte[] serializedLogEvent) {
     metrics.logMessagesBytesSent.inc(serializedLogEvent.length);
     metrics.logMessagesCountSent.inc();
     systemProducer.send(SOURCE, new OutgoingMessageEnvelope(systemStream, 
keyBytes, serializedLogEvent));