小编Pik*_*ppa的帖子

我正在编写一个 kibana 插件和一个 Logstash 管道。对于我的测试，我只是编写了一个像这样的 Logstash 输入：

input {

   beats {
        port => 9600
        ssl => false
        ssl_verify_mode => "none"
    }

}

但是当我尝试打开与节点的连接（上面的代码）时：

invoke = (parameters, id, port, host) => {
        var fs = require('fs');

        console.log(`Sending message in beats, host= ${host}, port= ${port}, message= ${parameters.message}`);

        var connectionOptions = {
            host: host,
            port: port
        };

        var client = lumberjack.client(connectionOptions, {rejectUnauthorized: false, maxQueueSize: 500});

        client.writeDataFrame({"line": id + " " + parameters.message});
    }

Logstash 给我“无效的 Beats 协议版本：22”和“无效的 Beats 协议版本：3”：

Caused by: org.logstash.beats.InvalidFrameProtocolException: Invalid …