我是kafka和kafkajs的新手。
我已经使用kafkaJS创建了一个Kafka生产者和消费者。
我想知道当消费者或生产者在与kafka服务器的连接上超时时,如何控制我的js代码上发生的事情。
我想在配置中一定有某种功能分配,但是到目前为止我在文档中找不到任何东西。
可以监听KafkaJS的检测事件的REQUEST_TIMEOUT事件
我是kafka和kafkajs的新手。
我已经使用kafkaJS创建了一个Kafka生产者和消费者。
我想知道当消费者或生产者在与kafka服务器的连接上超时时,如何控制我的js代码上发生的事情。
我想在配置中一定有某种功能分配,但是到目前为止我在文档中找不到任何东西。
可以监听KafkaJS的检测事件的REQUEST_TIMEOUT事件
javascript python java c# php android html jquery c++ css ios sql mysql arrays asp.net json python-3.x ruby-on-rails .net sql-server django objective-c excel regex ruby linux ajax iphone xml vba spring asp.net-mvc database wordpress string postgresql wpf windows xcode bash git oracle list vb.net multithreading eclipse algorithm macos powershell visual-studio image forms numpy scala function api selenium