Kafka 自身没有消息过滤的语义。实践中可以采取以下两个办法:
(1)如果过滤的种类不多,可以采取多个 Topic 的方式达到过滤的目的;
(2)如果过滤的种类多,则最好在客户端业务层面自行过滤。
实践中请根据业务具体情况进行选择,也可以综合运用上面两种办法。
Kafka 自身没有消息过滤的语义。实践中可以采取以下两个办法:
(1)如果过滤的种类不多,可以采取多个 Topic 的方式达到过滤的目的;
(2)如果过滤的种类多,则最好在客户端业务层面自行过滤。
实践中请根据业务具体情况进行选择,也可以综合运用上面两种办法。