I’m trying to use the ESPayloadEncoder documented here:
http://hekad.readthedocs.org/en/v0.8.2/config/encoders/index.html#config-espayload
This is the relevant config:
[es_payload]
index = "heka-%{Y.%m.%d}"
es_index_from_timestamp = true
type_name = "heka_logs"
[ElasticSearchOutput]
message_matcher = "TRUE"
server = "https://127.0.0.1:9200";
flush_interval = 5000
flush_count = 10
encoder = "es_payload"
When I start up hekad, I get this:
2015/01/09 11:07:21 Pre-loading: [es_payload]
2015/01/09 11:07:21 No registered plugin type: es_payload
2015/01/09 11:07:21 Pre-loading: [ElasticSearchOutput]
2015/01/09 11:07:21 Pre-loading: [LogstreamerInput]
2015/01/09 11:07:21 Pre-loading: [PayloadEncoder]
2015/01/09 11:07:21 Pre-loading: [LogOutput]
2015/01/09 11:07:21 Pre-loading: [ProtobufDecoder]
2015/01/09 11:07:21 Pre-loading: [ProtobufEncoder]
2015/01/09 11:07:21 Loading: [ProtobufDecoder]
2015/01/09 11:07:21 Loading: [PayloadEncoder]
2015/01/09 11:07:21 Loading: [ProtobufEncoder]
2015/01/09 11:07:21 Loading: [LogstreamerInput]
2015/01/09 11:07:21 Loading: [ElasticSearchOutput]
2015/01/09 11:07:21 Non-existent encoder 'es_payload' specified by output
'ElasticSearchOutput'
2015/01/09 11:07:21 Loading: [LogOutput]
2015/01/09 11:07:21 Error reading config: 2 errors loading plugins
1) See what I’m doing wrong? 2) I’m confused on whether to use ‘es_payload’ or
‘ESPayloadEncoder’. I’ve tried both with the same luck. The doc example uses
the former, but I don’t understand how that works. Examples for other encoders
user the full name (i.e., ESLogstashV0Encoder)
_______________________________________________
Heka mailing list
[email protected]
https://mail.mozilla.org/listinfo/heka
