《数据密集型应用系统设计》消息代理
消息代理其实指的就是消息队列，但是我认为作者这里...
如何保证消息恰好被消费一次？
因为业务逻辑从同步代码中移除，所以也要有相应队列...
大数据Presto三：Presto Connector连接器
Presto Connector支持从多种数据源读取数据，例如：...
进程间的六种通信方式
每个进程的用户地址空间都是独立的，一般而言是不能...
Kafka源码解析_kafka删除消费组命令
bin/kafka-topics.sh –zookeeper zk_host:port/chr...
Will not attempt to authenticate using SASL (unknown error) (org.apache.zookeepe
我通过docker命令启动kafka，进入kafka容器之后，过...
近九万字的RabbitMQ图文详解
RabbitMQ 简介：RabbitMQ 基于 AMQP 标准，采用 Erl...
研究Fabric中Etcd的Raft应用
Fabric的共识服务设计成了可插拔的模块，以此满足了...
《数据密集型应用系统设计》 - 数据编码和演化
本章的前半部分提到的编码框架目前在GO领域如鱼得水...
RocketMq 基本扫盲
本篇是RocketMq扫盲，并不会讲到各个组件实现的细节...
大厂都是如何处理重复消息的？
消息最多传递一次，如果当时客户端不可用，则会丢失...
Kafka原理解析
Kafka 是由 LinkedIn 开发的一个分布式的消息系统，...
大数据Kafka五：Kafka的java API编写
将 log4j.properties 配置文件放入到 resources 文件...
大数据Kafka三：Kafka的集群搭建以及shell启动命令脚本编写
为了方便将来进行一键启动、关闭Kafka，我们可以编写...