使用节点npm ksqldb-client抛出超时错误执行ksql查询

发布于 2025-01-26 08:38:18 字数 1050 浏览 5 评论 0原文

嗨，我正在尝试使用NPM软件包KSQLDB-CLIENT软件包执行KSQL查询，它会引发超时错误。我也附上了代码，请让我知道那里的任何问题。 当点get url下面的方法将执行https：// localhost：5000/testksql

exports.getKSQLStream = async () => {
    const options = {
        authorization: {
            username: "admin",
            password: "pw",
            ssl: {
                ca:  CAs,
                crt: myClientCert,
                key: myClientKey,
            }
        },
        host:  'https://ixxxx.xcxx.net',
        timeout: 20000
    }
    const client = new KsqldbClient(options);
    await  client.connect();
    const streamRes = await  client.query('list streams;');
    console.log("streams",streamRes);
    await  client.disconnect();
}

当我从邮递员中击中该URL时，在节点控制台中的响应低于响应。

Error on Http2 client. Error: connect ETIMEDOUT 16.2XX.X4.xxx:8088
    at TCPConnectWrap.afterConnect [as oncomplete] (net.js:1159:16) {
  errno: -4039,
  code: 'ETIMEDOUT',
  syscall: 'connect',
  address: '16.2XX.X4.xxx',
  port: 8088
}

原文

Hi am trying to execute the KSQL query using npm package ksqlDb-client package, it throws an timeout error. I have attached the code as well, please let me know any issues over there.
when am hit this GET URL below method will execute https://localhost:5000/testKsql

exports.getKSQLStream = async () => {
    const options = {
        authorization: {
            username: "admin",
            password: "pw",
            ssl: {
                ca:  CAs,
                crt: myClientCert,
                key: myClientKey,
            }
        },
        host:  'https://ixxxx.xcxx.net',
        timeout: 20000
    }
    const client = new KsqldbClient(options);
    await  client.connect();
    const streamRes = await  client.query('list streams;');
    console.log("streams",streamRes);
    await  client.disconnect();
}

when I hit that URL from postman am getting below response in node console.

Error on Http2 client. Error: connect ETIMEDOUT 16.2XX.X4.xxx:8088
    at TCPConnectWrap.afterConnect [as oncomplete] (net.js:1159:16) {
  errno: -4039,
  code: 'ETIMEDOUT',
  syscall: 'connect',
  address: '16.2XX.X4.xxx',
  port: 8088
}

分享到QQ

分享到微博