当kafkajs消费者或生产者超时时,在客户端检测和控制



我是kafka和kafkajs的新手。

我已经使用kafkaJS创建了一个Kafka生产者和消费者。

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

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

可以监听KafkaJS的检测事件的REQUEST_TIMEOUT事件

相关内容

  • 没有找到相关文章

最新更新