I am running into the same exact issue was well
Please find my pipeline below:
input {
websocket {
url => "wss://certstream.calidog.io"
codec => "json"
}
}
output {
elasticsearch {
hosts => [ "localhost:9200" ]
index => "calidog"
}
}
Error:
[WARN ] 2018-10-25 17:32:05.483 [[main]<websocket] websocket - websocket input client threw exception, restarting {:exception=>#<NoMethodError: undefined method `each' for #<FTW::Response:0x7279ccb8>>}