美文网首页
消费者消费方式

消费者消费方式

作者: Shaw_Young | 来源:发表于2022-02-15 11:04 被阅读0次

consumer采用pull(拉)模式从broker中读取数据。
push(推)模式很难适应消费速率不同的消费者,因为消息发送速率是由broker决定的。
它的目标是尽可能以最快的速度传递消息,但是这样很容易造成consumer来不及处理消息,典型的表现就是拒绝服务以及网络拥塞。而pull模式可以根据consumer的消费能力以适当的速率消费消息。
pull模式不足之处是,如果kafka没有数据,消费者可能会陷入循环中,一直返回空数据。针对这一点,Kafka的消费者在消费时会传入一个时长参数timeout,如果当前没有数据可供消费,consumer会等待一段时间之后再返回,这段时长即为timeout。

相关文章

  • 消费者消费方式

    consumer采用pull(拉)模式从broker中读取数据。push(推)模式很难适应消费速率不同的消费者,因...

  • kafka

    主题和分区 消息发送方式 消息顺序保证 分区 消费者 消费者005消费者01.PNG005消费者02.PNG005...

  • RocketMQ阅读笔记之消息消费的消息拉取

    消息消费,简而言之就是消费者从消息队列里读取数据。消费者有两种消费方式: Push方式。消息服务器接收到信息后,主...

  • RocketMQ源码阅读(十)-Consumer消费消息

    1.消费方式和消费者组 1.消费方式: 拉取和推送两种(事实上所有从远程获取数据都是这两种方式).2.消费者组与消...

  • RocketMQ集群模式与广播模式

    RocketMQ 消费者默认是集群的方式消费的,消费者还可以用广播的模式进行消费。 集群模式 当 Consumer...

  • 超级符号就是超级话语

    消费者行为是调研的关键 华与华常用的方式是举行消费者小组座谈会,用一种半催眠式的谈话方式,探索消费者的观点和行为,...

  • 打造品牌,走进消费者心里

    文:泡沫 所谓品牌传播,就是将品牌的各种信息通过不同方式传给消费者,攻占消费者心智,那对于消费者来说,接受信息有两...

  • 四 Kafka消费者 概念及Java API

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

  • kafka 使用注意

    kafka 消费者offset记录位置和方式 我们大家都知道,kafka消费者在会保存其消费的进度,也就是offs...

  • 20190316-《冲突》学习笔记-不同的战略阶段就需要选择不同

    想要→需要→必要。 这是一个品牌和消费者建立连接的方式,营销就是要和消费者建立连接,连接就需要路径,消费者和其他品...

网友评论

      本文标题:消费者消费方式

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