我想知道我们能不能在Kafka做服务器端过滤?支持服务器端过滤的替代方案有哪些?我的意思是,Kafka能否向客户端提供特定的消息,以避免在客户端进行过滤?
zynd9foi1#
关于服务器端过滤,我知道https://www.crankuptheamps.com/ (安培)支持它。您可以将筛选器附加到订阅,并且您将只接收与所述筛选器匹配的邮件。不过,它不是开源的,如果这对你来说不是一个破坏者,那就试试吧。
qco9c6ql2#
Kafka能否向客户提供特定的信息Kafka不是一个基于推的系统;它不“提供信息”。必须为消费者客户端分配要从中进行投票的主题。另一方面,生产者基于主题(例如,一个主题的用户注册事件和另一个主题的用户会话到期事件)或围绕其发送的数据的其他条件语句执行“过滤”;因此,客户端过滤。在生产者和消费者之间没有其他过滤 send() 最终消费者 poll() ,例如“服务器端”过滤。如果消费者只对记录的一个子集感兴趣,那么该客户必须与某个生产商达成共同协议,以获得特定的记录,否则,其他无关的记录必须被忽略或以其他方式处理。在kafka streams api中,您有 filter() 操作,这也是客户端过滤。支持服务器端过滤的替代方案有哪些?据我所知。。。如果消息代理隐藏消息以防被读取,那就很奇怪了
send()
poll()
filter()
2条答案
按热度按时间zynd9foi1#
关于服务器端过滤,我知道https://www.crankuptheamps.com/ (安培)支持它。您可以将筛选器附加到订阅,并且您将只接收与所述筛选器匹配的邮件。不过,它不是开源的,如果这对你来说不是一个破坏者,那就试试吧。
qco9c6ql2#
Kafka能否向客户提供特定的信息
Kafka不是一个基于推的系统;它不“提供信息”。必须为消费者客户端分配要从中进行投票的主题。
另一方面,生产者基于主题(例如,一个主题的用户注册事件和另一个主题的用户会话到期事件)或围绕其发送的数据的其他条件语句执行“过滤”;因此,客户端过滤。
在生产者和消费者之间没有其他过滤
send()
最终消费者poll()
,例如“服务器端”过滤。如果消费者只对记录的一个子集感兴趣,那么该客户必须与某个生产商达成共同协议,以获得特定的记录,否则,其他无关的记录必须被忽略或以其他方式处理。在kafka streams api中,您有
filter()
操作,这也是客户端过滤。支持服务器端过滤的替代方案有哪些?
据我所知。。。如果消息代理隐藏消息以防被读取,那就很奇怪了