发布与订阅消息系统 在正式讨论Apache Kafka (以下简称Kafka)之前，先来了解发布与订阅消息系统的概念， 并认识这个系统的重要性。...

引言 复习要点 本文大概围绕如下几点进行阐述: 为什么使用消息队列？使用消息队列有什么缺点?消息队列如何选型?如何保证消息队列是高可用的？如何保...

KafkaConsumer(消费者)每次调用 poll()方法，它总是返回由生产者写入 Kafka但还没有被消费者读取过的记录， 我们因 此可以...

应用程序使用 KafkaConsumer向 Kafka 订阅主题，并从订阅的主题上接收消息 。 从 Kafka 读取数据不同于从其他悄息系统读取...

不管是把 Kafka 作为消息队列、消息、总线还是数据存储平台来使用 ，总是需要有一个可以往 Kafka 写入数据的生产者和一个可以从 Kafk...

镜像下载、域名解析、时间同步请点击 阿里云开源镜像站[https://developer.aliyun.com/mirror/?utm_cont...

幂等性介绍 现如今很多系统都会基于分布式或微服务思想完成对系统的架构设计。那么在这一个系统中，就会存在若干个微服务，而且服务间也会产生相互通信调...

前提1.搭好SpringBoot集成RocketMQ环境代码。2.使用Docker安装RocketMQ以及它的控制台。 需求背景 用订单进行分区...