前面我们使用Helm在Kubernetes中部署了生产可用的Pulsar集群，并将集群接入到Prometheus监控系统。 作为Pulsar集群的管理员，将这套生产可用的Pulsar集群交付给开发使用时，还需要做好租户和命名空间划分和创建，用……

阅读全文

上一节，使用Pulsar官方的Helm Chart在Kubernetes集群中规划并部署了生产可用的Pulsar集群。 在上一节，我们还留了一个小尾巴，在部署Pulsar集群时，禁用了监控相关的组件(promethues, grafana等)。 在……

阅读全文

时间过得比较久了，在开始今天的学习之前先回顾一下前面已经学习的13节的内容。 0.阶段复习 Pulsar是一个支持多租户的、高性能的、分布式的Pub-Sub消息系统。 了解Pulsar的架构。Pulsar提供了一个比Cluster更高级别的抽象I……

阅读全文

上一节学习了如何为Pulsar开启基于JWT的身份认证。 Pulsar使用身份认证提供者(Authentication Provider)识别客户端，但如果只启用身份认证，那么只要客户端通过认证就可以访问集群中的所有资源，因此在启用身份认证的基……

阅读全文

Pulsar支持可插拔的身份认证和授权机制，Pulsar Proxy或者Pulsar Broker都支持该机制。认证和授权机制一起保证了客户端对Pulsar Topic、命名空间、租户的访问权限。 默认情况下，Pulsar并不会启用加密、身份认证和……

阅读全文

分区Topic的概念 前面在学习Topic的时候，已经了解了分区Topic的基本概念。在Pulsar中一个Topic只能由一个Broker提供服务，而单个Topic的吞吐量受限于为其提供服务的Broker的计算能力，这限制了Topic的最大吞……

阅读全文

主流消息系统都会提供很多好用的特性支持各种业务场景，死信队列, 延迟队列这些词在使用这些消息系统时经常被提到。 Pulsar作为下一代云原生消息系统肯定也是支持这些特性的。Pulsar中没有队列的概念， 前面在学习使用Java和Go开发Pulsa……

阅读全文

前面学习了Pulsar的架构，在本地开发环境中使用Docker运行了单机的Pulsar，并学习使用plusar-admin命令行工具管理集群、租户、命名空间和Topic，使用Java和Go开发Pulsar的Producer和Consumer……

阅读全文

前面两节分别介绍了如何使用Pulsar Java客户端库和Go客户端库开发Producer、Consumer。 目前主流的消息中间件都不负责消息在从生产者到消费者上下游传递过程中的类型安全性，而由客户端自己负责消息的序列化和反序列操作来保障消息……

阅读全文

上一节学习了Pulsar中的生产者、消费者、订阅和订阅类型。 当一个消费者连接到Pulsar时，会创建一个订阅(Subscription)，订阅有4种类型：独占模式、灾备模式、共享模式和基于key的共享模式。 订阅是命名好的配置规则，指导消息如……

阅读全文