小编mik*_*688的帖子

据说消费者只能阅读整个主题。没有运气对经纪人进行评估以过滤消息。

这意味着我们必须消费/接收来自主题的所有消息并在客户端过滤它们。

这太多了。我想知道我们是否可以根据已经传递给代理的东西（例如 msg 键或其他东西）过滤和接收特定类型的消息。

从方法Consumer.poll(timeout)来看，我们似乎没有多余的事情可以做。