诗意般的代码

主题、分区与副本 基本概念 主题、分区和副本的关系 主题是一个逻辑概念，代表了一类消息，实际工作中我们使用主题来区分业务，而主题之下并不是消息，而是分区，分区是一个物理概念，它是磁盘上的一个目录，目录中是保存消息的日志段文件。分区的目的是为了提高吞吐量，实现主题的负载均衡，一个主题至少有一个分区；而故障转移这个功能就放在了副本上，一个分区至少有一个副本，一个…

消息分区策略 这里不是说Kafka的主题为什么要分区，而是说在分区的结构下，如何让具有某种特点的消息发送到特定分区。 这里有一个很明显的问题，就是主题分区，那么生产者发送的消息到底被发送到了哪个分区呢？一般我们都知道有轮询机制或者是随机机制，这两种机制都比较好理解。而且Kafka也都支持，在新版本中默认使用的是轮询机制，如下图所示： 但是在某些场景下我们需要…