@blued-core-oversea/kafka-client

基于 kafka-node 的一层封装。

npm i @blued-core-oversea/kafka-client

import { KafkaClient } from '../index'

const kafka = {
  oversea: '/blued/backend/ukafka/oversea_app/bootstrap',
}

const kafkaClient = new KafkaClient(kafka)
export const liveLogKafkaClient = () => kafkaClient.getClient('oversea')

const testData = { timestamp: 1629460128, data: { uid: 90000024, extra: { event: 15, targetUid: 90000024, liveId: 0, taskLevel: '4', taskId: '8' } }, app: 2 }

export const sleep = (ms: number) => new Promise(resolve => setTimeout(resolve, ms))

const main = async () => {
  await sleep(1000)
  liveLogKafkaClient().send('xxxxxxx', JSON.stringify(testData))
  console.log('---------------over')
}

main().then(() => {
  kafkaClient.close()
  console.log('success')
}).catch(error => {
  console.log(error)
})