美文网首页
Kafka消费模式

Kafka消费模式

作者: Shaw_Young | 来源:发表于2022-01-21 18:25 被阅读0次

消息队列的两种模式

1)点对点模式(一对一,消费者主动拉取数据,消息收到后消息清除)

消息生产者生产消息发送到Queue中,然后消息消费者从Queue取出并且消费消息。消息被消费以后,queue中不再有存储,所以消息消费者不可能消费到已经被消费的消息。Queue支持存在多个消费者,但是对一个消息而言,只会有一个消费者可以消费。

2)发布/订阅模式(一对多,消费者消费数据之后不会清除消息)

消息生产者(发布)将消息发布到topic中,同时多个消息消费者(订阅)消费该消息。和点对点方式不同,发布到topic的消息会被所有订阅者消费。

相关文章

  • Flink kafka source源码解析(四)

    指定offset消费 消费模式 在flink的kafka source中有以下5种模式指定offset消费 默认为...

  • Kafka消费模式

    消息队列的两种模式 1)点对点模式(一对一,消费者主动拉取数据,消息收到后消息清除) 消息生产者生产消息发送到Qu...

  • Kafka消费者API总结

    相对于Kafka的生产者API,消费者的API略显繁杂,本文总结了0.11.0版本的kafka消费者的几种消费模式...

  • 探究kafka——概念篇

    kafka的基本概念 kafka特点1:是基于发布订阅模式,而非pear-pear模式,消费者可以有多个,实质是一...

  • 四 Kafka消费者 概念及Java API

    消费者 1. 消费方式 采取pull的模式从kafka集群获取消息。 push的模式很难适用于消费速率不同的消费者...

  • kafka 基于Partition 和group 消费,kafk

    kafka消费模式 基于partition 指定offset 基于group auto.offset.reset ...

  • kafka——消费者原理解析

    一、消费方式 kafka采用发布订阅模式:一对多。发布订阅模式又分两种: push(推)模式很难适应消费速率不同的...

  • python3读写kafka

    消费kafka数据,方式一 消费kafka数据,方式二 将消息写入kafka

  • 【Kafka】Kafka 常用命令

    本篇结构: kafka topic 管理脚本 kafka 生产者控制台 kafka 消费者控制台 kafka 消费...

  • Flink kafka source源码解析(二)

    offset提交模式(非checkpoint) 消费kafka topic最为重要的部分就是对offset的管理,...

网友评论

      本文标题:Kafka消费模式

      本文链接:https://www.haomeiwen.com/subject/prtyhrtx.html