KStream 过滤器是否消耗每条消息？

Question

我过去使用过 Kafka，但从未使用过流 API。我的任务是构建一个可扩展的服务，该服务接受 websocket 连接并根据用户 ID 将来自中心主题的出站消息路由到正确的会话。

使用 KStream 看起来非常简单。来自one online tutorial：

builder.stream(inputTopic, Consumed.with(Serdes.String(), publicationSerde))
        .filter((name, publication) -> "George R. R. Martin".equals(publication.getName()))
        .to(outputTopic, Produced.with(Serdes.String(), publicationSerde));

但是过滤器命令是否会消耗来自主题的每条消息并在应用程序空间中执行过滤器？或者 KStream filter(Predicate super K,? super V> predicate) 是否包含进入 Kafka 内部工作的钩子，只允许它接收匹配正确键的消息？

KStream javadoc 上的措辞似乎暗示了前者：“逐条消费消息。”

如果过滤器的唯一目的是消耗主题的每条消息并丢弃不相关的消息，我可以手动完成。

Answer 1

你是对的 - 消息需要反序列化，然后根据谓词检查（在应用程序空间中）

扔掉不相关的，我可以手动处理

当然可以，但 Kafka Streams 有用于 defining session windows 的有用方法。此外，您无需定义消费者和生产者实例来转发新主题。