简介:kafka是一种消息队列,主要是观察者模式(Obsever)一个分布式的发布、订阅的消息系统,支持海量数据的数据传递(高吞吐)。Kafka将消息持久化到磁盘中,并对消息创建了备份保证了数据的安全。Kafka在保证了较高的处理速度的同时,又能保证数据处理的低延迟和数据的零丢失,同时支持离线数据处理和实时数据处理。
kafka的两种消费模式:

  1. 点对点模式
    在这里插入图片描述
    描述:生产者发送消息到消息队列由消费者消费消息(允许多个消费者,但一个信息只能被一个消费者消费),消费者消费完成消息返回信息给消息队列,消息队列立刻删除已被消费的消息

  2. 发布订阅模式
    在这里插入图片描述
    描述:生产者发布消息到topic中,topic可以同时被多个消费者消费。在topic中被消费的消息不会立即删除,kafka它会默认再保存一段时间再删除。

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐