Kafka 自身没有消息过滤的语义。实践中可以采取以下两个办法：

• 如果过滤的种类不多，可以采取多个 Topic 的方式达到过滤的目的；
• 如果过滤的种类多，则最好在客户端业务层面自行过滤。

实践中请根据业务具体情况进行选择，也可以综合运用上面两种办法。