Review Board 1.7.22


Flume UDP Source for Windows Events being trimmed at \n characters by SyslogUtils.extractEvent() function

Review Request #9842 - Created March 10, 2013 and updated

Ambud Sharma
Reviewers
Flume
flume-git
Ref: https://issues.apache.org/jira/browse/FLUME-1938 
Functional test done resulting in full message body being written to file.
flume-ng-core/src/main/java/org/apache/flume/source/SyslogSourceConfigurationConstants.java
Revision 5a73c88 New Change
[20] 53 lines
[+20]
54
  public static final String CONFIG_CHARSET = "charset.default";
54
  public static final String CONFIG_CHARSET = "charset.default";
55

    
   
55

   
56
  public static final String DEFAULT_CHARSET = "UTF-8";
56
  public static final String DEFAULT_CHARSET = "UTF-8";
57

    
   
57

   
58
  public static final String CONFIG_PORT_CHARSET_PREFIX = "charset.port.";
58
  public static final String CONFIG_PORT_CHARSET_PREFIX = "charset.port.";

    
   
59
  public static final String CONFIG_IS_SYSLOG_MULTILINE_BODY = "body.multiline";
59

    
   
60

   
60
  public static final int DEFAULT_BATCHSIZE = 100;
61
  public static final int DEFAULT_BATCHSIZE = 100;
61

    
   
62

   
62
  public static final String CONFIG_PORT_HEADER = "portHeader";
63
  public static final String CONFIG_PORT_HEADER = "portHeader";
63

    
   
64

   
64
  public static final String DEFAULT_PORT_HEADER = "port";
65
  public static final String DEFAULT_PORT_HEADER = "port";

    
   
66
  public static final boolean DEFAULT_IS_SYSLOG_MULTILINE_BODY = false;
65

    
   
67

   
66
  public static final String CONFIG_READBUF_SIZE = "readBufferBytes";
68
  public static final String CONFIG_READBUF_SIZE = "readBufferBytes";
67
  public static final int DEFAULT_READBUF_SIZE = 1024;
69
  public static final int DEFAULT_READBUF_SIZE = 1024;
68

    
   
70

   
69
  private SyslogSourceConfigurationConstants() {
71
  private SyslogSourceConfigurationConstants() {
70
    // Disable explicit creation of objects.
72
    // Disable explicit creation of objects.
71
  }
73
  }
72

    
   
74

   
73
}
75
}
flume-ng-core/src/main/java/org/apache/flume/source/SyslogUDPSource.java
Revision 96a9e85 New Change
 
flume-ng-core/src/main/java/org/apache/flume/source/SyslogUtils.java
Revision c2a29a1 New Change
 
flume-ng-core/src/test/java/org/apache/flume/source/TestSyslogUtils.java
Revision 7208464 New Change
 
  1. flume-ng-core/src/main/java/org/apache/flume/source/SyslogSourceConfigurationConstants.java: Loading...
  2. flume-ng-core/src/main/java/org/apache/flume/source/SyslogUDPSource.java: Loading...
  3. flume-ng-core/src/main/java/org/apache/flume/source/SyslogUtils.java: Loading...
  4. flume-ng-core/src/test/java/org/apache/flume/source/TestSyslogUtils.java: Loading...