Skip to content

Instantly share code, notes, and snippets.

@ans-4175
Created March 17, 2016 06:46
Show Gist options
  • Save ans-4175/297e2b4fc0a67d826b4b to your computer and use it in GitHub Desktop.
Save ans-4175/297e2b4fc0a67d826b4b to your computer and use it in GitHub Desktop.
netcat beginning flume conf
# Name the components on this agent
Agent1.sources = netcat-source
Agent1.channels = memory-channel
Agent1.sinks = logger-sink
# Describe/configure Source
Agent1.sources.netcat-source.type = netcat
Agent1.sources.netcat-source.bind = localhost
Agent1.sources.netcat-source.port = 44444
# Describe the sink
Agent1.sinks.logger-sink.type = logger
# Use a channel which buffers events in memory
Agent1.channels.memory-channel.type = memory
Agent1.channels.memory-channel.capacity = 1000
Agent1.channels.memory-channel.transactionCapacity = 100
# Bind the source and sink to the channel
Agent1.sources.netcat-source.channels = memory-channel
Agent1.sinks.logger-sink.channel = memory-channel
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment