👩💻 Join our community of thousands of amazing developers!
今天开始准备制作聊天功能，希望使用kafka进行消息的读写操作，保障消息的可靠性，以及对mysql的持久化要求Kafka 基础概念Producer 和 Consumer对于kafka来说，有两种基本类型: Producer 和 ConsumerProducer 简单来说就是用来生产消息或者源信息的，而Consumer 则负责消费消息，使用消息Topic 和 PartitionTopic在kafka中，消息根据Topic进行分类，每个Topic对应一个消息队列。从大的来讲，我们可以将每个服务划分为一个Topic，数据按照服务进行分类处理。从小的来看，我们也能细化每个服务的增删改查操作，每个操作维护一个Topic，进行更细致的划分PartitionPartition是为了解决Topic内数据传输方式不同，导致单个Topic出现吞吐量不足的问题他将单个Topic分化为多个块，对内部以不同方式传输的数据进行分块处理，例如将发送消息与删除消息分为两块进行，提高了未分块时串行输出的效率Broker 和 Cluster一个kafka服务器称为一个Broker，多个Broker组成一个Cluster集...