Kafka,nodejs客户端(kafkaesque)套接字默认超时

Kafka, nodejs client (kafkaesque) socket default timeout

我正在使用 Ubuntu 14.04。一个 nodejs ->kafkaesque(kafka nodejs 客户端)->kafka_2.9.2-0.8.2.1->storm。在 Kafkaesque(kafka nodejs 客户端)中,我注意到在 api.js 中,有以下行来创建套接字。

 _socket = net.createConnection(_options.port, _options.host);

我想知道套接字超时的默认值是多少。如果我希望套接字连接始终为 there/permanent,我应该设置超时(0)吗?

我还注意到代码后面的一行:

_socket.on('timeout', function(){
      console.log('socket timeout');
    });

如果我想让套接字连接永久,我是否应该在这个超时函数中尝试重新建立连接?

来自net docs for Node.js

By default net.Socket do not have a timeout.

因此,除非在其他地方有 socket.setTimeout() 调用,否则套接字不应有超时。

另外:

When an idle timeout is triggered the socket will receive a 'timeout' event but the connection will not be severed. The user must manually end() or destroy() the socket.

因此当 timeout 事件触发时您不需要重新连接,除非回调与 end()destroy().

断开连接