0

我是 kafka 和 kafkajs 的新手。

我使用kafkaJS制作了一个 Kafka 生产者和消费者。

我想知道当消费者或生产者与 kafka 服务器的连接超时时,我如何控制我的 js 代码上发生的事情。

我想配置上一定有某种功能分配,但到目前为止我在文档上找不到任何东西。

4

1 回答 1

0

您可以侦听KafkaJS的检测事件的 REQUEST_TIMEOUT 事件

于 2021-12-09T04:04:40.407 回答