1 点对点模式

消息生产者把消息发送到Queue中,然后消费者从Queue中取出并且消费消息。消息被消费后Queue中不再存储,所以一个消息只可以被一个消费者消费。

2 发布订阅模式

生产者把消息发布到topic中,同时有多个消费者订阅该topic。和点对点不同,该消息会被所有的消费者消费
发布订阅有两种

2.1 消费者主动拉取消息

好处是消费者消费速度可以由消费者来确定。缺点是需要建立一个长轮询,不断的问消息,比较浪费资源。

2.2 队列主动推送

消息消费速度由队列决定。但是下游消费者消费能力参差不齐,如果推的速度过快则消费能力低的消费者容易崩溃,如果推送速度过慢则消费者不能充分消费。
kafka采用的是消费者主动拉取消息

Logo

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

更多推荐