Advertisement
Guest User

flume_helloworld

a guest
Jan 29th, 2018
81
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
  1.  
  2. # Name the components on this agent
  3. a1.sources = r1
  4. a1.sinks = k1
  5. a1.channels = c1
  6.  
  7. # Describe/configure the source
  8. a1.sources.r1.type = netcat
  9. a1.sources.r1.bind = localhost
  10. a1.sources.r1.port = 44444
  11.  
  12. # Describe the sink
  13. a1.sinks.k1.type = logger
  14.  
  15. # Use a channel which buffers events in memory
  16. a1.channels.c1.type = memory
  17. a1.channels.c1.capacity = 1000
  18. a1.channels.c1.transactionCapacity = 100
  19.  
  20. # Bind the source and sink to the channel
  21. a1.sources.r1.channels = c1
  22. a1.sinks.k1.channel = c1
  23.  
  24.  
  25.  
  26.  
  27. bin/flume-ng agent --conf conf --conf-file conf/example.conf --name a1 -Dflume.root.logger=INFO,console
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement