PAGE1

PAGE1

消息队列：Kafka：Kafka高级特性：事务与幂等性

1Kafka基础回顾

1.1Kafka消息传递模型

Kafka是一种分布式流处理平台，它以一种高吞吐量、低延迟的方式处理大量实时数据。Kafka的核心概念是消息队列，但它的设计更接近于一个分布式日志系统。在Kafka中，数据被组织成主题（Topic），每个主题可以被分区（Partition）以实现并行处理和数据的持久化存储。生产者（Producer）将消息发送到主题，而消费者（Consumer）则订阅主题以消费消息。Kafka通过Zookeeper进行集群管理和配置，确保数据的可靠性和一致性。