document.write('
Data hosted with ♥ by Pastebin.com - Download Raw - See Original
  1. # Sources, channels and sinks are defined per agent,
  2. # in this case called 'agent'
  3.  
  4. agent.sources = reader
  5. agent.channels = memoryChannel
  6. agent.sinks = avro-forward-sink
  7.  
  8. # For each one of the sources, the type is defined
  9. agent.sources.reader.type = exec
  10. agent.sources.reader.command = tail -f /var/log/flume-ng/source.txt
  11. # stderr is simply discarded, unless logStdErr=true
  12. # If the process exits for any reason, the source also exits and will produce no further data.
  13. agent.sources.reader.logStdErr = true
  14. agent.sources.reader.restart = true
  15.  
  16. # The channel can be defined as follows.
  17. agent.sources.reader.channels = memoryChannel
  18.  
  19. # Each sink's type must be defined
  20. agent.sinks.avro-forward-sink.type = avro
  21. agent.sinks.avro-forward-sink.hostname = 10.240.242.93
  22. agent.sinks.avro-forward-sink.port = 60000
  23.  
  24. #Specify the channel the sink should use
  25. agent.sinks.avro-forward-sink.channel = memoryChannel
  26.  
  27. # Each channel's type is defined.
  28. agent.channels.memoryChannel.type = memory
  29.  
  30. # Other config values specific to each type of channel(sink or source)
  31. # can be defined as well
  32. # In this case, it specifies the capacity of the memory channel
  33. agent.channels.memoryChannel.capacity = 10000
  34. agent.channels.memoryChannel.transactionCapacity = 100
');