kafka-client

基于 kafka-node 的一层封装。

npm i @blued-core/kafka-client

cache 与 qconf-conf 组件都为可选的，可以自己根据描述自定义

使用方式：

import KafkaClient from '@blued-core/kafka-client'
import { QconfConf } from '@blued-core/qconf-conf'
import Cache from '@blued-core/cache'

async function main () {
  const qconfConf = new QconfConf({
    path: 'XXXX'
  })

  const kafkaClient = new KafkaClient(qconfConf, new Cache())

  const bootstrapKafka = kafkaClient.getClient('path')

  bootstrapKafka.send('topics', 'Hello World')
}

main()

API

send

参数	类型	是否必填	描述
topic	string	✅	消息对应的 topic
message	string	✅	消息体
options	Object	❌	发送消息时的部分参数

options 结构描述

参数	类型	描述
key	string	only needed when using keyed partitioner
partition	number	写入的分区
attributes	number