全部,原谅我我是一个新手,只是初学者Kafka
。目前我正在阅读关于the difference between traditional message system like Active MQ
and Kafka
的文档Kafka
。卡夫卡消息处理如何在发布 - 订阅模式下扩展?
作为文件。
对于传统的消息系统。他们无法扩展消息处理。 由于
发布 - 订阅模式可以让你广播数据到多个进程,但 没有缩放处理的方式,因为每个消息发送到每一个 用户。
我觉得这对我有意义。
但是对于Kafka
。文档说,即使在发布 - 订阅模式下,Kafka
也可以扩展消息处理。 (请纠正我,如果我错了,谢谢。)
卡夫卡的消费群体概念概括了这两个概念。由于具有队列的 消费者组允许您在一组进程(消费者组的成员)上划分处理 。由于 与发布 - 订阅,卡夫卡允许您广播消息到 多个消费群体。
卡夫卡的模型的优点是,每个主题都有两种属性 - 它可扩展的处理,也是多用户 -there 是没有必要选择一个或另一个。
所以我的问题是如何Kafka
使它?我的意思是在发布 - 订阅模式下缩放处理。谢谢。
感谢您的审查和回答问题。据我所知。传统的消息传递可以在集群模式下执行#1。对? (PS:我想弄明白Kafka比传统消息传递有什么优势。) –
#2。如果代理未跟踪消息消息,则确认。 'Kafka'如何确保消息在处理过程中不会丢失?谢谢。 –
不,传统消息传递即使在集群模式下也不会执行#1。如果消息是持久的,则传统消息将所有消息存储在单个主节点中(不分区),然后将整个消息存储复制到其他节点以实现容错。 –