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