我可以根据 Kafka 中的特定条件消费吗？

Question

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

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

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

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

Answer 1

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

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