kafka 的基本使用
Apache Kafka是一个开源的分布式流处理平台，最初由LinkedIn开发，主要用于构建实时数据管道和流处理应用程序，高效处理大量数据流。
其核心概念包括：**主题（Topic）**用于消息分类；**生产者（Producer）**发布消息；**消费者（Consumer）**订阅消息，可通过**消费者组（Consumer Group）**实现负载均衡；**代理（Broker）**是Kafka服务器，负责存储和处理数据；**分区（Partition）**将主题数据细分，提升并行度和吞吐量，并确保分区内消息有序；**偏移量（Offset）**标识消息在分区中的位置。
Kafka具备高吞吐量、可扩展性、持久性、容错性和实时性等特点。消息模型支持发布订阅和点对点模式。自Kafka 2.8起，引入**KRaft模式**替代ZooKeeper进行元数据管理，简化了部署和运维。用户可通过命令行工具快速部署Kafka集群，管理主题，并进行消息的生产和消费。
