Skip to content

Instantly share code, notes, and snippets.

@harageth
Created May 14, 2018 18:42
Show Gist options
  • Save harageth/7e22e119ac9c9fba81da72875b3d1dcc to your computer and use it in GitHub Desktop.
Save harageth/7e22e119ac9c9fba81da72875b3d1dcc to your computer and use it in GitHub Desktop.
Flume thrift source logger sink config
flume.sources = thriftSource
flume.channels = fileChannel
flume.sinks = loggerSink
flume.sources.thriftSource.type = thrift
flume.sources.thriftSource.bind = localhost
flume.sources.thriftSource.port = 4141
# flume.sources.thriftSource.channels = memoryChannel
flume.sources.thriftSource.channels = fileChannel
# flume.sources.stressSource.type = org.apache.flume.source.StressSource
# flume.sources.stressSource.size = 1024
# flume.sources.stressSource.maxTotalEvents = 100000000000
# flume.sources.stressSource.channels = fileChannel
# flume.sources.stressSource.channels = memoryChannel
flume.sinks.loggerSink.type = logger
flume.sinks.loggerSink.channel = fileChannel
# flume.channels.memoryChannel.type = memory
# flume.channels.memoryChannel.capacity = 6000000
# flume.channels.memoryChannel.transactionCapacity = 10000
flume.channels.fileChannel.type = file
flume.channels.fileChannel.checkpointDir = ./checkpoint
flume.channels.fileChannel.dataDirs = ./metrics
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment