我正在尝试构建一个分析引擎来确定客户端使用的url\events的实时分析,以及记录api的性能。以下是我计划实施的逻辑:1创建筛选器以拦截URL2代码过滤器是一个可重用的jar,它具有使用mvc拦截器拦截它们的逻辑。三。如果url模式匹配,拦截器将生成事件并将其发布到kafka流中。我的困惑是,这是实现这一目标的最佳途径。或者有没有其他更好的方法,记住API的高流量。
jchrr9hc1#
如果一次只过滤一条消息,也可以在kafka connect中使用新的单一消息转换功能进行过滤https://cwiki.apache.org/confluence/display/kafka/kip-66%3a+single+message+transforms+for+kafka+connect
1条答案
按热度按时间jchrr9hc1#
如果一次只过滤一条消息,也可以在kafka connect中使用新的单一消息转换功能进行过滤https://cwiki.apache.org/confluence/display/kafka/kip-66%3a+single+message+transforms+for+kafka+connect