heka-redis
heka-redis copied to clipboard
How to get redis datas by heka-redis?
Hi Victor,
How to get redis datas by heka-redis? The detail is in following.
Thanks.
[root@localhost heka]# vim wax.toml
[hekad] maxprocs = 8
[RedisPubSubInput] address = "172.16.89.199:6601" channel = "wax_log"
[PayloadEncoder] append_newlines = false prefix_ts = true ts_format = "2006/01/02 3:04:05PM MST"
[LogOutput]
message_matcher = "TRUE"
encoder = "PayloadEncoder"
[debug] type = "LogOutput" message_matcher = "Type == 'redis_pub_sub'" encoder = "PayloadEncoder"
[root@localhost heka]# bin/hekad -config wax.toml 2015/06/03 11:14:26 Pre-loading: [debug] 2015/06/03 11:14:26 Pre-loading: [RedisPubSubInput] 2015/06/03 11:14:26 Pre-loading: [PayloadEncoder] 2015/06/03 11:14:26 Pre-loading: [ProtobufDecoder] 2015/06/03 11:14:26 Loading: [ProtobufDecoder] 2015/06/03 11:14:26 Pre-loading: [ProtobufEncoder] 2015/06/03 11:14:26 Loading: [ProtobufEncoder] 2015/06/03 11:14:26 Pre-loading: [TokenSplitter] 2015/06/03 11:14:26 Loading: [TokenSplitter] 2015/06/03 11:14:26 Pre-loading: [HekaFramingSplitter] 2015/06/03 11:14:26 Loading: [HekaFramingSplitter] 2015/06/03 11:14:26 Pre-loading: [NullSplitter] 2015/06/03 11:14:26 Loading: [NullSplitter] 2015/06/03 11:14:26 Loading: [PayloadEncoder] 2015/06/03 11:14:26 Loading: [RedisPubSubInput] 2015/06/03 11:14:26 Loading: [debug] 2015/06/03 11:14:26 Starting hekad... 2015/06/03 11:14:26 Output started: debug 2015/06/03 11:14:26 MessageRouter started. 2015/06/03 11:14:26 Input started: RedisPubSubInput 2015/06/03 11:14:26 Input 'RedisPubSubInput': Subscription: psubscribe wax_log 1