无法连接到 Kafka 服务器的 TCP 套接字

Question

我启动了简单的kafka服务器。参见 quick start section

我无法连接到上述服务器。这是我的代码：

Deno.listen({ port: 9092, transport: 'tcp' });
// or
Deno.listen({ port: 9092, hostname: 'localhost', transport: 'tcp' });
//or
Deno.listen({ port: 9092, hostname: '127.0.0.1' });

这是错误：

error: Uncaught PermissionDenied: An attempt was made to access a socket in a way forbidden by its access permissions. (os error 10013)
    at unwrapResponse ($deno$/ops/dispatch_json.ts:43:11)
    at Object.sendSync ($deno$/ops/dispatch_json.ts:72:10)
    at Object.listen ($deno$/ops/net.ts:51:10)
    at Object.listen ($deno$/net.ts:152:22)
    at Object.listen ($deno$/net_unstable.ts:36:12)
    at file:///D:/rust/deno/index.ts:10:6

我试过的命令

deno run --allow-net --allow-write ./index.ts
deno run --allow-net --unstable ./index.ts
deno run --allow-net  ./index.ts

在 Rust 的帮助下，我可以毫无问题地连接到上述服务器。这是我的 Rust 代码：

fn connect() -> Result<(), std::io::Error> {
    let stream = TcpStream::connect("localhost:9092").expect("Could not connect");
}

我是 Deno 新手。我做错了什么？

Answer 1

用Deno.listen you're creating a server on port 9002, not connecting to the Kafka server. You should use Deno.connect代替。

const conn = await Deno.connect({ hostname: "localhost", port: 9092 });
console.log("Connected", conn);

const decoder = new TextDecoder();
const encoder = new TextEncoder();
await conn.write(encoder.encode("message"));

// Read response
const buf = new Uint8Array(1024);
await conn.read(buf);
console.log('Client - Response:', decoder.decode(buf))


conn.close();

无法连接到 Kafka 服务器的 TCP 套接字

Unable to connect to TCP socket of Kafka server

typescript

apache-kafka

tcp

deno