Skip to content

Instantly share code, notes, and snippets.

@harageth
Created December 19, 2017 21:12
Show Gist options
  • Save harageth/7086c09bdc39326b7918130df0f05bfa to your computer and use it in GitHub Desktop.
Save harageth/7086c09bdc39326b7918130df0f05bfa to your computer and use it in GitHub Desktop.
test.sources = thriftSource
test.channels = fileChannel
test.sinks = outLogger
# A single thrift source to send to all channels
test.sources.thriftSource.type = thrift
test.sources.thriftSource.bind = localhost
test.sources.thriftSource.port = 7878
test.sources.thriftSource.threads = 20
test.sources.thriftSource.channels = fileChannel
# A unique file channel for each sink
test.channels.fileChannel.type = file
test.channels.fileChannel.capacity = 2000000
# test.channels.fileChannel.dataDirs = <%= @runPath %>/kafka-<%= dc %>/metrics
test.channels.fileChannel.transactionCapacity = 10000
# test.channels.fileChannel.sinks = outLogger
test.sinks.outLogger.type = logger
test.sinks.outLogger.channel = fileChannel
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment