Kafka 消费者监听两个事件/主题

【问题标题】：Kafka consumer listening to two events/topicsKafka 消费者监听两个事件/主题
【发布时间】：2020-07-29 05:25:38
【问题描述】：

有什么办法可以消费两个主题并等待这两个事件继续消费？

【问题讨论】：

标签： node.js apache-kafka kafka-consumer-api

【解决方案1】：

有什么办法可以消费两个主题？

您可以在 Kafka 消费者中消费多个主题。如果您使用的是KafkaJS，那么这里是example，下面是一个sn-p

// 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 })

请注意，消费者将不会匹配在订阅后创建的主题

【讨论】：