[使用Kafka侦听器vs Kafka使用者获取具有指定密钥的消息

问题描述 投票:0回答:1

我使用SpringBoot应用制作或消费/收听Kafka消息。

我在主题中产生一条消息,并消费/收听通过比较messageKey特定的消息,然后发送已消耗的消息以进行进一步处理。

我坚持使用哪种方法更适合我的要求以获得特定消息,即Kafka ListenerKafka Consumer什么?

apache-kafka kafka-consumer-api
1个回答
0
投票

[KafkaListener是包装Kafka Consumer API的Spring特定概念。

无法通过给定键的特定偏移量获取消息。您必须计算分区,然后扫描整个偏移量

© www.soinside.com 2019 - 2024. All rights reserved.