kafka instance

TIP

kafka Instance

connect ()

连接Instance

例 :

 await instance.connect()

disconnect ()

断开连接

例 :

 await instance.disconnect()

send (topic, message)

发送消息

参数类型作用备注
topicstringkafka topic
messagestring消息内容

例 :

 await instance.send('test','test message')