我使用SpringBoot应用制作或消费/收听Kafka消息。
我在主题中产生一条消息,并消费/收听通过比较messageKey特定的消息,然后发送已消耗的消息以进行进一步处理。
我坚持使用哪种方法更适合我的要求以获得特定消息,即Kafka Listener或Kafka Consumer什么?
[KafkaListener是包装Kafka Consumer API的Spring特定概念。
无法通过给定键的特定偏移量获取消息。您必须计算分区,然后扫描整个偏移量