使用 Kafka Listener 与 Kafka Consumer 获取具有指定密钥的消息答案

【问题标题】：Fetch message with specified key using Kafka Listener vs Kafka Consumer使用 Kafka Listener 与 Kafka Consumer 获取具有指定密钥的消息
【发布时间】：2020-06-17 17:03:45
【问题描述】：

我使用 SpringBoot App 来生产或消费/收听 Kafka 消息。

我在主题中生成一条消息并使用/收听具体消息通过比较messageKey然后发送消费消息以供进一步处理。

我不知道哪种方法更适合我获取特定消息的要求，即 Kafka Listener 或 Kafka Consumer 什么？

【问题讨论】：

标签： apache-kafka kafka-consumer-api

【解决方案1】：

KafkaListener 是封装了 Kafka Consumer API 的 Spring 特定概念。

没有办法通过给定键的特定偏移量获取消息。你必须计算分区，然后扫描整个偏移量

【讨论】：