我正在研究Apache Kafka，我的用例要求客户端能够过滤消息，并且过滤发生在代理而不是客户端上。此要求与使用JMS选择器相同。
据我了解，尽管我可能不正确，但Kafka没有选择器，并且过滤是在客户端上完成的。因此，所有消息都发送给客户端，客户端负责过滤。
无论如何，是否有实现JMS Selector方法（在代理上进行过滤）的方法？
不，你不能那样做。最好的办法是在客户端进行过滤。Apache Kafka API仅支持“从偏移量X开始，给主题N分区M最多给我1兆字节的消息”的获取。
您可以参考“有线协议”参考以查看获取请求的可能选项，但其中不包含您要查找的任何内容。
实际上，Kafka之所以快，是因为每次获取都只是顺序读取，所以我认为这不会在将来的版本中实现（但是如果我错了，我会很高兴的：）。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句