Skip to content
This repository has been archived by the owner on Apr 2, 2024. It is now read-only.

StreamOutput stopped: can't get record: can't unmarshal record: proto: illegal wireType 6 ? #1989

Open
wangfeiping opened this issue Nov 14, 2016 · 0 comments

Comments

@wangfeiping
Copy link

I run hekad on a lot of server, but just one server show error log and shut down.
All the server is same, same system, same path, same config.
I don't know why, every time I restart hekad then the server will show me the log!

2016/11/14 10:12:33 Plugin 'o' error: StreamOutput stopped: can't get record: can't unmarshal record: proto: illegal wireType 6
2016/11/14 10:12:33 Plugin 'o' error: can't get record: can't unmarshal record: proto: illegal wireType 6
2016/11/14 10:12:33 Plugin 'o': stopped
2016/11/14 10:12:33 Plugin 'o': has stopped, shutting down.

`
[hekad]
maxprocs = 1
base_dir = "/apps/heka-0_10_0-linux-amd64/bin"
share_dir = "/apps/heka-0_10_0-linux-amd64/bin"

[ks]
type = "RegexSplitter"
delimiter = ''
delimiter_eol = true

[pd]
type = "PayloadRegexDecoder"
match_regex = '(?P[\s\S]*)'

[pd.message_fields]
Logger = "xml_log"
Payload = "{{pay_mpos_front_cnepay}}%msg%"

[file_input]
type = "LogstreamerInput"
log_directory = "/apps/front_cnepay/log"
file_match = 'front_cnepay.log'
splitter = "ks"
decoder = "pd"

[PayloadEncoder]
append_newlines = false

[o]
type = "TcpOutput"
address = "logs.qianbao.com:516"
message_matcher = "Logger=='xml_log'"
encoder = "PayloadEncoder"
`

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant