-
14. 如何保证消息的顺序性？
14. 如何保证消息的顺序性？ 14. 如何保证消息的顺序性？ 不同的消息队列，其架构不同，所以实现消息的顺序性的方案不同。 在保证消息顺序性方面，RabbitMQ、RocketMQ和Kafka各有其独特的实现机制： RabbitMQ ： RabbitMQ通过拆分队列（多个queue）或使用内存队列来保证消息的顺序性。 通过确认模式（ack... -
83.Kafka 如何保证消息的顺序性？
83.Kafka 如何保证消息的顺序性？ 83.Kafka 如何保证消息的顺序性？ Kafka 本身，并不像 RocketMQ 一样，提供顺序性的消息。所以，提供的方案，都是相对有损的。如下： 这里的顺序消息，我们更多指的是，单个 Partition 的消息，被顺序消费。 方式一，Consumer ，对每个 Partition 内部单线程... -
18.查看、修改和删除主题
查看主题 修改主题 删除主题 查看主题 第16节中提及了 kafka-topics.sh 脚本有5种指令类型：create、list、describe、alter 和 delete。其中 list 和 describe 指令可以用来方便地查看主题信息，在前面的内容中我们已经接触过了 describe 指令的用法，本节会对其做更细致的讲述。 通过... -
28.Kafka Connect
Kafka Connect 独立模式 REST API 分布式模式 Kafka Connect Kafka Connect 是一个工具，它为在 Kafka 和外部数据存储系统之间移动数据提供了一种可靠的且可伸缩的实现方式。Kafka Connect 可以简单快捷地将数据从 Kafka 中导入或导出，数据范围涵盖关系型数据库、日志和度量数据、Ha... -
64.Kafka 的应用场景有哪些？
64.Kafka 的应用场景有哪些？ 64.Kafka 的应用场景有哪些？ Kafka 的应用场景 1）消息队列 比起大多数的消息系统来说，Kafka 有更好的吞吐量，内置的分区，冗余及容错性，这让 Kafka 成为了一个很好的大规模消息处理应用的解决方案。消息系统一般吞吐量相对较低，但是需要更小的端到端延时，并常常依赖于 Kafka 提供的... -
88.为什么kafka这么快
为什么Kafka这么快？ 一、顺序IO 二、内存映射文件 三、零拷贝 四、应用层面的优化 写在后面 为什么Kafka这么快？ 很多人都知道Kafka吞吐量高，延迟低，那么为什么Kafka会这么快？如果在面试中被问到这个问题，你会回答吗？如果你一脸懵逼地看着面试官，面试官可能不会很生气，但是后果可能很严重。因为在面试官的眼里，你可能只是个会写... -
1.初识Kafka
初识Kafka 基本概念 初识Kafka Kafka 起初是 由 LinkedIn 公司采用 Scala 语言开发的一个多分区、多副本且基于 ZooKeeper 协调的分布式消息系统，现已被捐献给 Apache 基金会。目前 Kafka 已经定位为一个分布式流式处理平台，它以高吞吐、可持久化、可水平扩展、支持流数据处理等多种特性而被广泛使用。目前越... -
21.优先副本的选举
优先副本的选举 优先副本的选举 分区使用多副本机制来提升可靠性，但只有 leader 副本对外提供读写服务，而 follower 副本只负责在内部进行消息的同步。如果一个分区的 leader 副本不可用，那么就意味着整个分区变得不可用，此时就需要 Kafka 从剩余的 follower 副本中挑选一个新的 leader 副本来继续对外提供服务。虽然不... -
74.Kafka 的消息格式是怎么样的？
74.Kafka 的消息格式是怎么样的？ 74.Kafka 的消息格式是怎么样的？ message 中的物理结构为： message 物理结构 参数说明： 关键字 解释说明 8 byte offset 在parition(分区)内的每条消息都有一个有序的id号，这个id号被称为偏移(offset),它可以唯一确定每条消息... -
36. 写在最后
写在最后 写在最后 学习到这里，相信读者可以应付 Kafka 绝大多数的使用场景，这里虽然是本小册《图解Kafka之实战指南》的终点，但绝不是你学习 Kafka 的终点，在学习消化完本小册之后，建议读者继续学习[《图解Kafka之核心原理》],里面有更核心的知识点等着大家去掌握。 在小册开始介绍的部分中有一处“你会学到什么？”的地方，里面笔者列举了...