node.js - Kafka 消费者监听两个事件/主题
问题描述
有什么办法可以消费两个主题并等待这两个事件继续消费?
解决方案
有什么办法可以消费两个主题吗?
您可以在 Kafka 消费者中消费多个主题。如果您正在使用KafkaJS
,那么这里是示例,下面是一个片段
// Subscribe can be called several times
await consumer.connect()
await consumer.subscribe({ topic: 'topic-B' })
await consumer.subscribe({ topic: 'topic-C' })
// Alternatively, you can subscribe to multiple topics at once using a RegExp:
await consumer.connect()
await consumer.subscribe({ topic: /topic-(eu|us)-.*/i })
注意消费者不会匹配订阅后创建的主题
推荐阅读
- angular - 救援专家:无法解析组件错误的所有参数
- c - Linux 进程堆栈被局部变量溢出(堆栈保护)
- c++ - C++ 部分模板模板特化
- android - 在android中触摸时获取图形的x和y坐标
- php - 如何上传文件 - PHP?
- sql - 从多个列中选择一个值并在 Oracle SQL Developer 中使用所选值创建一个新列
- css - Angular Universal 未加载 angular.json 文件中给出的样式
- groovy - katalon studio 偶尔打开浏览器
- wso2 - 使用登录和订阅权限向 WSO2 API-M 添加新角色不允许用户登录订阅者门户
- angular - 在 SweetAlert 中添加组件