nodejs中操作kafka生产和消费消息示例代码

代码语言:nodejs

所属分类:通讯

代码描述:nodejs中操作kafka生产和消费消息示例代码

代码标签: nodejs 操作 kafka 生产 消费 消息 示例 代码

下面为部分代码预览,完整代码请点击下载或在bfwstudio webide中打开

const { Kafka } = require('kafkajs')

const kafka = new Kafka({
  clientId: 'my-app',
  brokers: ['localhost:9092']
})

const producer = kafka.producer()
const consumer = kafka.consumer({ groupId: 'test-consumer-group' })

const run = async () => {
  // Producing生产消息
  await producer.connect()
  await producer.send({
    topic: 'test-topic',
    messages: [
      { value: 'He.........完整代码请登录后点击上方下载按钮下载查看

网友评论0