[FLUME-2917] Provide netcat UDP source as alternative to TCP - ASF JIRA

Attach files

Attach Screenshot

Voters

Watch issue

Watchers

Create sub-task

Link

Clone

Update Comment Author

Replace String in Comment

Update Comment Visibility

Delete Comments

XML

Word

Printable

JSON

Details

Type: New Feature
Status: Resolved
Priority: Minor
Resolution: Fixed
Affects Version/s: 1.6.0
Fix Version/s: 1.8.0
Component/s: Sinks+Sources
Labels:
None

Description

Currently Flume provides a Netcat TCP source, however Netcat is often used with UDP. There is an implementation of a UDP client in the SyslogUDP source, this request takes this implementation and strips out the Syslog parts, thus forming a Netcat UDP source - where each datagram is recorded as a Flume event.

The implementation is provided for this at https://github.com/tmgstevens/FlumeNetcatUDPSource and also provided as an attached patch for inclusion.

N.B. Unit tests are provided for this.