今天收到球友的问题，让推荐一些值得看的开源项目，觉得netty这些太复杂了不太好上手。确实如此，我们日常常用的Spring、Netty确实由于发展了多年，看起来比较头大。下面我来推荐一些我看过同时觉得不错的项目(几乎都是我参与过的），由易到难，其中也会包含Java和Go的项目，包含主流

本文主要介绍使用 Java 来操作Pulsar，文中所使用到的软件版本：Java17.0.7(Pulsar服务使用)、Java1.8.0_341(客户端使用)、Pulsar3.3.0、pulsar-client3.3.0。1、引入依赖<dependency><groupId>org.apache.pulsar</groupId><artifactId>pulsar-client</artifact

本文分享自《华为云DTSE》第五期开源专刊，作者：贺张俭华为云IoT技术专家随着物联网平台业务的快速增长，基于传统消息中间件构筑面临着处理亿级设备连接和海量数据的挑战。本文分析了消息中间件的架构发展趋势以及核心优势，还探讨了ApachePulsar在华为云IoT平台上的实践应用，展示了华

功能Pulsar是一种用于服务器到服务器消息传递的多租户、高性能解决方案。Pulsar最初由Yahoo开发，由Apache软件基金会管理。Pulsar是由Apache软件基金会开发的分布式发布/订阅消息系统，它结合了传统消息系统（如RabbitMQ）和发布-订阅系统（如ApacheKafka）的最佳特性，为可伸缩

本文主要介绍Pulsar的命令行使用，相关的环境及软件信息如下：CentOS7.9.2009、Pulsar3.3.0、Java17.0.10。1、环境配置在 conf/client.conf中配置Pulsar相关地址：webServiceUrl=http://10.49.196.30:8080,10.49.196.31:8080,10.49.196.32:8080brokerServiceUrl=pulsar:/

PulsarMeetup北京2024PulsarMeetup北京2024活动将于2024年9月22日（周日）由谙流科技和小红书联合举办。诚邀Pulsar和各大社区的小伙伴、广大技术爱好者、架构师和企业代表参与。主办单位：AscentStream谙流科技、小红书活动时间：2024年9月22日14:00-18:00活

本文主要介绍Pulsar的安装，相关的环境及软件信息如下：CentOS 7.9.2009、Pulsar3.3.0、Java17.0.10。1、单机版安装为了本地开发和测试，可以以单机模式运行Pulsar。单机模式将所有组件运行在单个Java虚拟机（JVM）进程内。官网(https://pulsar.apache.org/download/)下载安装包

本文主要介绍Pulsar的特性及架构，对应的pulsar版本为3.3.x。1、Pulsar特性Pulsar实例原生支持多个集群，并且在集群之间实现了无缝的地理复制消息。极低的发布和端到端延迟。无缝扩展至超过一百万个主题。简单的客户端API，支持Java、Go、Python和C++语言。多种订阅

MessagingJMSJMS关键类，如下：jakarta.jms.ConnectionFactoryjakarta.jms.ConnectionJmsTemplateActiveMQPropertiesActiveMQConnectionFactoryCustomizerJmsListenerContainerFactoryDefaultJmsListenerContainerFactoryMessageConverterDefaultJmsListenerContain

本文主要介绍Pulsar消息传递的相关概念，对应的pulsar版本为3.3.x。1、概述Pulsar基于发布-订阅模式构建。在这种模式中，生产者将消息发布到主题；消费者订阅这些主题，处理传入的消息，并在处理完成后向broker发送确认。当创建订阅时，即使消费者断开连接，Pulsar也会保留所有消

前段时间在pulsar-client-go社区里看到这么一个issue：import"github.com/apache/pulsar-client-go/pulsar"client,err:=pulsar.NewClient(pulsar.ClientOptions{URL:"pulsar://localhost:6650",})iferr!=nil{log.Fatal(err)}consumer,er

背景Pulsar有提供一个查询Broker负载的接口：/***Getloadforthisbroker.**@return*@throwsPulsarAdminException*/LoadManagerReportgetLoadReport()throwsPulsarAdminException;publicinterfaceLoadManagerReportextends

本文分享自华为云社区《华为云IoT开源专家实践分享：开源让物联网平台更开放、易用》，作者：华为云社区精选。“如果现在要对我打一个工作无关标签的话，那我想我现在是开源爱好者，最佳实践探索者。”这是张俭对自己的定位，可见其对开源的热忱。张俭认为，开源，意味着开放、共享、互助、共赢

背景前两天收到业务反馈有一个topic的分区消息堆积了：根据之前的经验来看，要么是业务消费逻辑出现问题导致消费过慢，当然也有小概率是消息队列的Bug（我们使用的是pulsar）。排查通过排查，发现确实是在一点多的时候消息堆积了（后面是修复之后堆积开始下降）。于是我在刚才堆积处查

背景时间过得很快啊，一转眼已经到了2024年，还记得15年刚工作那会掌握个SSM/H(Spring/Struts2/Mybatis/Hibernate)框架就能应付大部分面试了。现在CS专业的新同学估计都没听说过SSM

PulsarPulsar为什么要学习ApachePulsar什么是云原生DevOps：指的就是开发和运维不再是分开的两个团队，而是你中有我，我中有你的一个团队。微服务：指是应用需要具备低耦合+高内聚。持续交付：指的在不影响用户使用服务的前提下，频繁将新功能发布给用户使用，当然这一点也是云原生中比

今天是春节的最后一天，因为工作上临时有点事，很不情愿的打开电脑看着也就10天没看代码觉得非常陌生。之后便准备将迟迟未写的2023总结补完，这个传统从16年至今已经坚持将近7年时间了，今年当然也不能意外。健身今年要说最让我印象深刻的事就是健身了，为此我投入了大量的时间。

本文分享自华为云社区《Pulsar消息积压topic级别策略老化的两种方案》，作者：张俭。Pulsar像大多数消息中间件一样,支持按时间和大小对消息积压进行老化。但是默认的策略只能在namespace级别配置。本文将介绍如何在topic级别实现老化策略的两种方案。方案一：开启TopicLevelPolicy

本文分享自华为云社区《Pulsar消息积压topic级别策略老化的两种方案》，作者：张俭。Pulsar像大多数消息中间件一样,支持按时间和大小对消息积压进行老化。但是默认的策略只能在namespace级别配置。本文将介绍如何在topic级别实现老化策略的两种方案。方案一：开启TopicLevelPolicy来

Pulsar3.0介绍Pulsar3.0是Pulsar社区推出的第一个LTS长期支持版本。如图所示，LTS版本会最长支持到36个月，而Feature版本最多只有六个月；类似于我们使用的JDK11,17,21都是可以长期使用的；所以也推荐大家都升级到LTS版本。作为首个LTS版本，3.0自然也是自带了许多

(milvus本地集群部署非k8s)部署etcd和minio使用docker-compose部署，docker-compose.yml内容如下:version:'3.5'services:etcd:container_name:milvus-etcdimage:quay.io/coreos/etcd:v3.5.5environment:-ETCD_AUTO_COMPACTION_MODE=revision

1、背景Helm 是一个 Kubernetes 的包管理工具，有点类似于 Mac 上的 brew，Python 中的 PIP；可以很方便的帮我们直接在 kubernetes 中安装某个应用。比如我们可以直接使用以下命令方便的在k8s集群安装和卸载 MySQL：helminstallmy-sqloci://registry-1.docker.io/bit

@[toc]导图PreMQ-闲聊MQ一二事儿（Kafka、RocketMQ、Pulsar）MQ发展史基于JMS协议发展出来的ActiveMQ因为功能和稳定性问题，用的人比较少。AMQP是一个消息队列协议规范，它不是一款具体的消息队列。因为不同消息队列的访问协议是不一样的，导致不同的消息队列需要用不同的SDK访

关于PulsarSummitPulsarSummit是ApachePulsar社区年度盛会，它将分布在世界各地的ApachePulsar项目Contributor、Committer和各企业CTO/CIO、开发者、架构师、数据科学家，以及消息和流计算社区的精英召集在一起。于此盛会，大家分享实践经验、交流想法、探讨关于Pulsar项

背景前段时间业务团队偶尔会碰到一些Pulsar使用的问题，比如消息阻塞不消费了、生产者消息发送缓慢等各种问题。虽然我们有个监控页面可以根据topic维度查看他的发送状态，比如速率、流量、消费状态等信息。但也有几个问题：无法在应用维度查看他所依赖的所有topic的各种