[jira] [Updated] (FLUME-2823) Flume-Kafka-Channel with new APIs

2016-03-20 Thread Jeff Holoman (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated FLUME-2823: Attachment: FLUME-2823v6.patch > Flume-Kafka-Channel with new APIs > ---

[jira] [Commented] (FLUME-2823) Flume-Kafka-Channel with new APIs

2016-03-20 Thread Hari Shreedharan (JIRA)
[ https://issues.apache.org/jira/browse/FLUME-2823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15203491#comment-15203491 ] Hari Shreedharan commented on FLUME-2823: - This looks good, but the tests are hang

SyslogUDPSource input format

2016-03-20 Thread Chris Horrocks
Hi, I’ve been using flume-ng to ingest data into Kafka for approx 18 months. I’ve deployed agents into a multi-vendor environment and have been struggling with processing a number of syslog formats (rfc and non-rfc compliant) in a consistent way. Looking at the SyslogUtils code influme-ng-core