主页 / 问题 / 1535965
Accepted
Ruslan
Asked:2023-08-15 15:15:54 +0000 UTC2023-08-15 15:15:54 +0000 UTC

kafkajs断开连接需要很长时间

  • 772

我正在使用kafkajs lib进行自动测试。

调用时await consumer.disconnect()，命令执行约 5 秒，是否有安全快速断开连接的选项？

javascript

1 个回答

  1. Best Answer
    The maximum amount of time in milliseconds the server will block before 
answering the fetch request if there isn’t sufficient data to immediately 
satisfy the requirement given by minBytes

    minBytes: 0因此，有必要设置maxWaitTimeInMs: 0

    kafka 中的默认值maxWaitTimeInMs: 5000（毫秒），minBytes: 1

    const consumer = this.client.consumer({
    minBytes: 0, // достаточно любой из этих опций
    maxWaitTimeInMs: 0,
    ...
});
    • 0

相关问题