kafka instance
TIP
kafka Instance
connect ()
连接Instance
例 :
await instance.connect()
disconnect ()
断开连接
例 :
await instance.disconnect()
send (topic, message)
发送消息
| 参数 | 类型 | 作用 | 备注 |
|---|---|---|---|
| topic | string | kafka topic | |
| message | string | 消息内容 |
例 :
await instance.send('test','test message')