spring-kafka - Kafka Consumer 的基于 Web 的过滤器

Question

我们目前有一个基于 Spring 的 Web 应用程序，它有一堆过滤器，可以进行身份​​验证和数据添加等。我们正在研究基于事件的系统，使用 Spring-kafka 作为实现，因此当前的过滤器不能在基于事件的情况下调用方法。现在有一种与传输无关的方法来实现相同的目标。有没有一种方法/方法可以用于基于 Web 的请求和基于事件的请求，它完全模仿了过滤器可以为 Web 请求做的事情。我知道 Spring Kafka 提供了一个 RecordInterceptor 接口，但我不能在基于 Web 的请求中使用它。

标签： spring-kafka

Answer 1

您必须将代码放在一个公共类中，并从记录拦截器和 Web 过滤器中调用它。

没有可用的通用 API。