filter拦截器kafka主题

p5cysglq  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(376)

我正在尝试构建一个分析引擎来确定客户端使用的url\events的实时分析,以及记录api的性能。
以下是我计划实施的逻辑:
1创建筛选器以拦截URL
2代码过滤器是一个可重用的jar,它具有使用mvc拦截器拦截它们的逻辑。
三。如果url模式匹配,拦截器将生成事件并将其发布到kafka流中。
我的困惑是,这是实现这一目标的最佳途径。或者有没有其他更好的方法,记住API的高流量。

jchrr9hc

jchrr9hc1#

如果一次只过滤一条消息,也可以在kafka connect中使用新的单一消息转换功能进行过滤https://cwiki.apache.org/confluence/display/kafka/kip-66%3a+single+message+transforms+for+kafka+connect

相关问题