Skip to content

Instantly share code, notes, and snippets.

@rafrombrc
Created July 7, 2015 18:19
Show Gist options
  • Save rafrombrc/2f64e7738f7bee09eb35 to your computer and use it in GitHub Desktop.
Save rafrombrc/2f64e7738f7bee09eb35 to your computer and use it in GitHub Desktop.
Carbon TCP reconnect example
[hekad]
share_dir = "/home/rob/go/heka/build/heka/share/heka"
[StatsdInput]
[StatAccumInput]
emit_in_fields = true
ticker_interval = 1
[PayloadEncoder]
[CarbonTcpOutput]
encoder = "PayloadEncoder"
address = "localhost:2003"
type = "TcpOutput"
message_matcher = "Type == 'heka.statmetric'"
keep_alive = true
thor [heka] git:dev ~/go/heka/build $ hekad -config=../etc/carbon.toml
2015/07/07 11:16:11 Pre-loading: [CarbonTcpOutput]
2015/07/07 11:16:11 Pre-loading: [StatsdInput]
2015/07/07 11:16:11 Pre-loading: [StatAccumInput]
2015/07/07 11:16:11 Pre-loading: [PayloadEncoder]
2015/07/07 11:16:11 Pre-loading: [ProtobufDecoder]
2015/07/07 11:16:11 Loading: [ProtobufDecoder]
2015/07/07 11:16:11 Pre-loading: [ProtobufEncoder]
2015/07/07 11:16:11 Loading: [ProtobufEncoder]
2015/07/07 11:16:11 Pre-loading: [TokenSplitter]
2015/07/07 11:16:11 Loading: [TokenSplitter]
2015/07/07 11:16:11 Pre-loading: [HekaFramingSplitter]
2015/07/07 11:16:11 Loading: [HekaFramingSplitter]
2015/07/07 11:16:11 Pre-loading: [NullSplitter]
2015/07/07 11:16:11 Loading: [NullSplitter]
2015/07/07 11:16:11 Loading: [PayloadEncoder]
2015/07/07 11:16:11 Loading: [StatsdInput]
2015/07/07 11:16:11 Loading: [StatAccumInput]
2015/07/07 11:16:11 Loading: [CarbonTcpOutput]
2015/07/07 11:16:11 Starting hekad...
2015/07/07 11:16:11 Output started: CarbonTcpOutput
2015/07/07 11:16:11 MessageRouter started.
2015/07/07 11:16:11 Input started: StatsdInput
2015/07/07 11:16:11 Input started: StatAccumInput
2015/07/07 11:16:24 Plugin 'CarbonTcpOutput' error: writing to localhost:2003: write tcp 127.0.0.1:2003: broken pipe
2015/07/07 11:16:25 Plugin 'CarbonTcpOutput' error: dial tcp 127.0.0.1:2003: connection refused
2015/07/07 11:16:26 Plugin 'CarbonTcpOutput' error: dial tcp 127.0.0.1:2003: connection refused
2015/07/07 11:16:27 Plugin 'CarbonTcpOutput' error: dial tcp 127.0.0.1:2003: connection refused
2015/07/07 11:16:29 Plugin 'CarbonTcpOutput' error: dial tcp 127.0.0.1:2003: connection refused
2015/07/07 11:16:46 Plugin 'CarbonTcpOutput' error: writing to localhost:2003: write tcp 127.0.0.1:2003: broken pipe
2015/07/07 11:16:47 Plugin 'CarbonTcpOutput' error: dial tcp 127.0.0.1:2003: connection refused
2015/07/07 11:16:48 Plugin 'CarbonTcpOutput' error: dial tcp 127.0.0.1:2003: connection refused
2015/07/07 11:16:49 Plugin 'CarbonTcpOutput' error: dial tcp 127.0.0.1:2003: connection refused
2015/07/07 11:16:51 Plugin 'CarbonTcpOutput' error: dial tcp 127.0.0.1:2003: connection refused
2015/07/07 11:16:53 Plugin 'CarbonTcpOutput' error: dial tcp 127.0.0.1:2003: connection refused
^C2015/07/07 11:16:59 Shutdown initiated.
2015/07/07 11:16:59 Stop message sent to input 'StatsdInput'
2015/07/07 11:16:59 Stop message sent to input 'StatAccumInput'
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment