apache-kafka - 我可以根据Kafka中的特定条件进行消费吗？

Question

我正在向 Kafka 写入一条消息并在另一端使用它。 在其中进行一些处理并将其写回另一个 Kafka 主题。

我想知道哪个消息响应针对哪个请求..

目前决定从消费者端捕获偏移 ID，然后写入响应并读取响应负载并做出相同的决定。

对于这种方法，我们需要读取每条消息，是否有其他方法可以根据消费者配置条件进行消费？

Answer 1

消费者只能阅读整个主题。您只能通过 seek() 跳过消息，但没有可以在代理上评估的条件来过滤消息。

您将需要在客户端中使用整个主题的进程/过滤器。