首页
学习
活动
专区
圈层
工具
发布

Pulsar 能否超越 Kafka?

Pulsar 是类似于 Kafka 的一个消息中间件,是 Yahoo 开源的,可以说 Pulsar 就是针对 Kafka 的痛点而来的。...下面就说说 Kafka 都有哪些痛点,以及 Pulsar 的优质特性,当然还会说下它的不足。 1....Yahoo、Verizon、Twitter 等很多公司都在使用 Pulsar 来处理海量消息。 Pulsar 声称比 Kafka 更快、运行成本更低、解决了很多 Kafka 的痛点。...小结 Pulsar 的确弥补了 Kafka 的很多不足,因为 Yahoo 就是为了解决这些问题而开发的 Pulsar。...但 Pulsar 也有明显的弱势,例如它的普及度比 Kafka 差太多了,而且 Kafka 有 Confluent 的专业支持,这个支持力度不是 Pulsar 能比的,由此就带来了其他问题,比如扩展插件太少

1.6K10
  • 您找到你想要的搜索结果了吗?
    是的
    没有找到

    为什么放弃Kafka,选择Pulsar?

    Yahoo、Verizon、Twitter 等很多公司都在使用 Pulsar 来处理海量消息。 Pulsar 声称比 Kafka 更快、运行成本更低、解决了很多 Kafka 的痛点。...Pulsar 非常灵活,可以像Kafka 一样作为分布式日志系统,也可以作为类似RabbitMQ 这类简单的消息系统。 Pulsar 有多种订阅类型、传递保障、保存策略。...Functions Pulsar Function 是一种部署简单,轻量级计算、对开发人员友好的 API,无需像 Kafka 那样运行自己的流处理引擎。...支持多种开发语言 例如 Go、Java、Scala、Node、Python 等等 为什么选择 Pulsar 目前业界使用比较多的是 Kafka,主要场景是大数据日志处理,较少用于金融场景。...Kafka、RocketMQ 和 Pulsar 的对比如下: ?

    1.3K20

    浅谈RocketMQ、Kafka、Pulsar的事务消息

    RocketMQ、Kafka和Pulsar都是当今业界应用十分广泛的开源消息队列(MQ)组件,笔者在工作中遇到关于MQ选型相关的内容,了解到关于“事务消息”这个概念在不同的MQ组件里有不同内涵。...常见的主流消息队列有ActiveMQ、RabbitMQ、ZeroMQ、Kafka、MetaMQ、RocketMQ、Pulsar等。...Pulsar 的事务处理流程与 Kafka 的事务处理思路大致上保持一致,大家都有一个 TC 以及对应的一个用于持久化 TC 所有操作的 Topic 来记录所有事务状态变更的请求。...第二:由于 Kafka 本身没有单条消息的 Ack,所以 Kafka 的事务处理只能是顺序执行的,当一个事务请求被阻塞之后,会阻塞后续所有的事务请求,但是 Pulsar 是可以对消息进行单条 Ack 的...参考文章【万字长文】浅谈Apache Kafka --- 入门须知Apache Pulsar 技术系列 - 事务消息pulsar官方doc消息队列(MQ)架构篇之RocketMQApache Pulsar

    2.7K22

    浅谈 RocketMQ、Kafka、Pulsar 的事务消息

    RocketMQ、Kafka 和 Pulsar 都是当今业界应用十分广泛的开源消息队列(MQ)组件,笔者在工作中遇到关于 MQ 选型相关的内容,了解到关于“事务消息”这个概念在不同的 MQ 组件里有不同内涵...常见的主流消息队列有 ActiveMQ、RabbitMQ、ZeroMQ、Kafka、MetaMQ、RocketMQ、Pulsar 等。...Pulsar 的事务处理流程与 Kafka 的事务处理思路大致上保持一致,大家都有一个 TC 以及对应的一个用于持久化 TC 所有操作的 Topic 来记录所有事务状态变更的请求。...第二:由于 Kafka 本身没有单条消息的 Ack,所以 Kafka 的事务处理只能是顺序执行的,当一个事务请求被阻塞之后,会阻塞后续所有的事务请求,但是 Pulsar 是可以对消息进行单条 Ack 的...Pulsar 的事务消息和 Kafka 应用场景和语义类似,只是由于底层实现机制有差别,在一些细节上有区别。 相信看到这里就非常清楚了,对于事务消息如何选型和应用,首先要明白你的业务需求是什么。

    1.7K50

    Kafka、Pulsar、RabbitMQ还是...

    目前最为我们所熟知的消息队列有:ActiveMQ、Kafka、RabbitMQ、Pulsar和RocketMQ,他们都有哪些优势和劣势, 我们应该如何选择呢?相信这是摆在很多开发者面前的问题。...1.5、Pulsar Pulsar是一种开源的分布式消息中间件系统,由Apache Software Foundation维护和支持。...目前,AMQP协议已经得到了广泛的应用,许多消息队列系统如RabbitMQ、ActiveMQ、Qpid等都支持AMQP协议,而Kafka与Pulsar则不支持标准AMQP。...三、消息队列对比 ActiveMQ RabbitMQ RocketMQ Kafka Pulsar 单机吞吐量 较低(万级) 一般(万级) 高(十万级) 高(十万级) 高(十万级) 开发语言 Java...如果是大数据领域的实时计算、日志采集等场景,则选择Kafka和Pulsar都是一个不错的选择,Kafka经历了超大规模应用的验证,社区活跃度很高,性能也非常高,几乎是全世界这个领域的事实性的标准。

    5.1K20

    MQ - 闲聊MQ一二事儿 (Kafka、RocketMQ 、Pulsar )

    Pulsar诞生于此背景下,目的是解决雅虎内部重复建设、消息队列隔离不好、数据迁移难等问题。 Pulsar通过提供平台化的消息队列服务来解决这些问题。...我们将首先介绍 Kafka、RocketMQ 和 Pulsar 的架构特点,然后比较它们在架构上的不同之处,以及这些不同之处如何影响它们的功能特性。...---- Pulsar 架构图(分层+分片) pulsar 相比与 kafka 与 rocketmq 最大的特点则是使用了分层和分片的架构,回想一下 kafka 与 rocketmq,一个服务节点即是计算节点也是服务节点...---- 扩容 当存储节点资源不足的时候,常规的运维操作就是动态扩容,相比 kafka 与 rocketmq、pulsar 不用考虑原数据的"人为"搬移工作,而是动态新增一个或者多个节点,broker...以下是一张 kafka 分区和 pulsar 分片的一张对比图,左图是 kafka 的数据存储特点,因为数据和分区的强绑定,导致了第三艘小船没有任何的数据,而相比 pulsar,数据不和任何存储节点绑定

    1.1K10

    最新基准测试:Kafka、Pulsar 和 RabbitMQ 哪个最快?

    路由键被引入用来模仿主题分区的概念,实现与 Kafka 和 Pulsar 相当的设置。...与 Kafka 和 Pulsar 不同的是,RabbitMQ 在主题中没有分区的概念。...图 13:Kafka、Pulsar 和 RabbitMQ 的端到端延迟,测量时 Kafka 和 Pulsar 的速率为 200K 消息 / 秒(消息大小 1 KB),RabbitMQ 的速率为 30K...在 Kafka 将每条消息 fsync 到磁盘(绿色虚线)的可选配置下,我们发现,Kafka 仍然比 Pulsar 延迟低,几乎一直到 p99.9 百分位,而 Pulsar(蓝色线)在更高的尾部百分位上表现更好...尽管对 Kafka 和 Pulsar 不公平,但我们发现,在不提供高可用性的配置下把 RabbitMQ 与 Kafka&Pulsar 进行比较很有趣,后两者都以较低的延迟为代价,提供了更强的持久性保证,

    2.8K20

    Kafka、RabbitMQ、Pulsar、RocketMQ基本原理和选型

    Kafka保证每个分区只能被一个消费者使用。Offset:偏移量是一种元数据,是不断递增的整数。在消息写入时Kafka会把它添加到消息里。在分区内偏移量是唯一的。...消费过程中,会将最后读取的偏移量存储在Kafka中,消费者关闭偏移量不会丢失,重启会继续从上次位置开始消费。Broker:独立的Kafka服务器。...使用场景日志收集:大量的日志消息先写入kafka,数据服务通过消费kafka消息将数据落地;消息系统:解耦生产者和消费者、缓存消息等;用户活动跟踪:kafka经常被用来记录web用户或者app用户的各种活动...当集群扩容时,Pulsar会在新增BookKeeper和Segment(即 Bookeeper 的 Ledger),不需要像kafka一样在扩容时进行Rebalance。...Topic的 Ledger 和 Fragment 之间映射关系等元数据存储在 Zookeeper 中,Pulsar Broker 需要实时跟踪这些关系进行读写流程;Ledger:即Segment,Pulsar

    2.5K31

    RocketMQ、Kafka、Pulsar全方位对比

    RocketMQ、Kafka和Pulsar都是当今业界应用十分广泛的开源消息队列(MQ)组件,笔者在工作中遇到关于MQ选型相关的内容,了解到关于“事务消息”这个概念在不同的MQ组件里有不同内涵。...常见的主流消息队列有ActiveMQ、RabbitMQ、ZeroMQ、Kafka、MetaMQ、RocketMQ、Pulsar等。...Pulsar的事务处理流程与Kafka的事务处理思路大致上保持一致,大家都有一个TC以及对应的一个用于持久化TC所有操作的Topic来记录所有事务状态变更的请求。...第二:由于Kafka本身没有单条消息的Ack,所以Kafka的事务处理只能是顺序执行的,当一个事务请求被阻塞之后,会阻塞后续所有的事务请求,但是Pulsar是可以对消息进行单条Ack的,所以在这里每一个事务的...【万字长文】浅谈Apache Kafka---入门须知 2. Apache Pulsar技术系列-事务消息 3. 消息队列(MQ)架构篇之RocketMQ 4.

    1.6K21

    大伙评评理,Kafka与Pulsar 谁更牛?

    (3)实时流数据管道:Kafka与Pulsar可以构建实时流数据管道,流数据管道从MySQL、MongoDB等数据源加载数据到Kafka与Pulsar中,其他系统或应用就可以稳定地从Kafka与Pulsar...为此,Kafka提供了Kafka Connect模块,Pulsar提供了Pulsar IO模块,它们都可以构建实时流数据管道。...为此,Kafka提供了Kafka Streams模块,Pulsar提供了Pulsar Functions模块,它们都可以实现流计算应用。...本文介绍了Kafka与Pulsar的起源发展与系统特性,以及Kafka与Pulsar中最基本的核心概念。...▊《深入理解Kafka与Pulsar:消息流平台的实践与剖析》 梁国斌 著 详细介绍Kafka与Pulsar的使用方式 深入分析Kafka与Pulsar的实现原理 本书详细介绍了Kafka与Pulsar

    91740

    CTO问我Pulsar到底能不能取代Kafka

    Pulsar是一款分布式发布/订阅消息平台,近两年非常火,被称为下一代的消息流平台,大有取代Kafka的势头。今天我们就来比较一下Pulsar跟Kafka。...架构 Kafka Kafka架构由broker和zookeeper组成,如下图: [1] 注意:Kafka2.8版本可以不依赖Zookeeper独立运行了 Pulsar Pulsar的架构如下: Pulsar...Broker会在本地缓存消息,并且支持TTL, 从上面的2个架构我们看到,Kafka和Pulsar有3点不同: Pulsar采用分层架构,将计算和存储相分离,存储使用BookKeeper集群,计算使用...Pulsar为实例中的每个租户分配: 授权机制 适用于租户配置的集群配置 Kafka Kafka为了控制客户端对broker资源的限制,从0.9版本引入了配额(quotas)管理,强制客户端请求使用配额...但这并不能说明Pulsar可以取代Kafka,Kafka用户群体庞大,社区和资源完善,而且在2.8版本中去除了Zookeeper,部署非常容易。毕竟不是每家公司都需要Yahoo和腾讯这样的集群体量。

    1.1K10
    领券