8篇文章 · 13092字 · 7人关注
1. Kafka消息存储 我么知道,Kafka中一个Topic由多个partition组成。Kafka会为每个partition按照topicN...
Kafka在0.11版本中除了引入了Exactly Once语义[https://www.jianshu.com/p/0943bbf482e9]...
消息送达语义是消息系统中一个常见的问题,主要包含三种语义: At most once:消息发送或消费至多一次 At least once:消息发...
Kafka中的每个partition都由一系列有序的、不可变的消息组成,这些消息被连续的追加到partition中。partition中的每个消...
在新建一个Consumer时,我们可以通过指定groupId来将其添加进一个Consumer Group中。Consumer Group是为了实...
Kafka最早是linkedin公司用于日志处理的分布式消息队列。现在它的功能远不止消息队列这么简单。根据Kafka官网的定义,Kafka是一个...
考虑一个分布式场景中一个常见的场景:服务A执行某个数据库操作成功后,会发送一条消息到消息队列,现在希望只有数据库操作执行成功才发送这条消息。下面...
1. 下载Kafka 2.10安装包 下载Kafka 2.10压缩包,下载地址: https://www.apache.org/dyn/clos...
文集作者