1. 云栖社区>
  2. 全部标签>
  3. #Consumer#
Consumer

#Consumer#

已有0人关注此标签

内容分类:
博客 | 问答 | 视频 | 资料 |

Pulsar与Kafka消费模型对比

kafka kafka 属于 Stream 的消费模型,为了支持多 partition 的消费关系,引入了 consumer group 的概念,同时支持在消费端动态的 reblance 操作,当多个 Consumer 订阅了同一个 Topic 时,会根据分区策略进行消费者订阅分区的重分配。

云栖社区 大数据 Image Consumer stream Pulsar

消息系统端到端Exactly-Once支持

消息系统对于消息的写入和消费提供多种模式,如 at-most-once,at-least-once 和 exactly-once,本文探讨如何在一个消息提供中高效支持exactly-once的写入和消费

消息系统 日志服务 SLS Consumer kafka plusar

Dubbo 路由规则和权重的生效时机

这里的 Invoker 是 Provider 的一个可调用 Service 的抽象,Invoker 封装了 Provider 地址及 Service 接口信息 Directory 代表多个 Invoker,可以把它看成 List ,但与 List 不同的是,它的值可能是动态变化的,比如注册中心...

云栖社区 算法 集群 负载均衡 Consumer list service

Dubbo Consumer 初始化连接过程

开篇 这篇文章的目的在于梳理Dubbo Consumer的连接过程,在这个过程中会涉及Exchanger、Transporter、NettyClient的整个过程梳理。 在这个过程中会涉及到ChannelHandler的封装过程,调用过程中会涉及ChannelHandler的调用过程分析。

云栖社区 string static url Consumer class handler bootstrap

Dubbo Admin 2.7.X 初探

开篇 为了统一不同配置中心(如Zookeeper、Nacos、Etcd等)对于服务治理规则的实现,Dubbo2.7.3及之后的版本针对2.7.0以来的配置中心的部分实现进行了重构。 从实际代码来看,Dubbo Admin针对应用纬度的配置的实际生效需要在Dubbo 2.7.3及以后的版本,为了方便debug建议Dubbo的版本是dubbo-2.7.4.1。

云栖社区 Apache 配置 runtime Server Consumer scope demo type service github

Dubbo 动态规则配置分析

开篇 覆盖规则是Dubbo设计的在无需重启应用的情况下,动态调整RPC调用行为的一种能力。 在Dubbo2.6及更早版本中,所有的服务治理规则都只针对服务粒度(service),如果要把某条规则作用到应用粒度上,需要为应用下的所有服务(service)配合相同的规则,变更,删除的时候也需要对应的操作。

云栖社区 java Apache 配置 string url Consumer list

Dubbo 标签路由

开篇 Dubbo路由规则在发起一次RPC调用前起到过滤目标服务器地址的作用,过滤后的地址列表,将作为消费端最终发起RPC调用的备选地址。 目前支持的路由包括:条件路由。支持以服务或Consumer应用为粒度配置路由规则。

云栖社区 Apache request string Consumer class Registry schema demo alibaba service

阿里巴巴 Service Mesh 落地的架构与挑战

云原生已成为整个阿里巴巴经济体构建面向未来的技术基础设施,Service Mesh 作为云原生的关键技术之一,顺利完成在 双11 核心应用严苛而复杂场景下的落地验证。本文作者将与大家分享在完成这一目标过程中我们所面临和克服的挑战。

RPC 架构 基础设施 集群 电商 脚本 Consumer service

阿里云物联网平台设备数据转发到消息队列RocketMQ全链路测试

您可以使用规则引擎,将物联网平台数据转发到消息队列(RocketMQ)中存储。从而实现消息从设备、物联网平台、RocketMQ到应用服务器之间的全链路高可靠传输能力。文本从物联网平台的产品及设备的创建开始,逐步介绍整个链路的完整实现。

云栖社区 Java核心技术 消息队列 logger 测试 控制台 aliyun string static exception Consumer 物联网 void PUT session

剖析nsq消息队列(四) 消息的负载处理

剖析nsq消息队列-目录 实际应用中,一部分服务集群可能会同时订阅同一个topic,并且处于同一个channel下。当nsqd有消息需要发送给订阅客户端去处理时,发给哪个客户端是需要考虑的,也就是我要说的消息的负载。

消息队列 Go MQ Consumer NSQ nsqd

表格存储如何在控制台使用多元索引(SearchIndex)功能

# 背景: 多元索引(SearchIndex)是TableStore 2018年重点打造的核心能力,目的是为在线数据平台(TableStore)提供丰富的查询能力, 目前提供了多种索引能力,包括倒排索引、多维空间索引等。

阿里技术协会 sdk 工单 排序 Image cdn 控制台 索引 string Consumer 表格存储

Context-React跨组件访问数据的利器

  Context-React跨组件访问数据的利器  Context提供了一种跨组件访问数据的方法。它无需在组件树间逐层传递属性,也可以方便的访问其他组件的数据  在经典的React应用中,数据是父组件通过props向子组件传递的。

react 函数 Consumer Render class

Kafka数据如何同步至MaxCompute之实践讲解

本次分享主要介绍Kafka产品的原理和使用方式,以及同步数据到MaxCompute的参数介绍、独享集成资源组与自定义资源组的使用背景和配置方式、Kafka同步数据到MaxCompute的开发到生产的整体部署操作等内容。

消息队列 日志 配置 Image 同步 Consumer 数据同步 MaxCompute

React新Context API在前端状态管理的实践

11/10号文档资料已全面更新!;《【阿里P7】Android高级教程+BAT面试题》,可复制链接后用石墨文档 App 或小程序打开:【阿里P7】移动互联网架构师进阶高级教程+BAT面试题众所周知,React的单向数据流模式导致状态只能一级一级的由父组件传递到子组件,在大中型应用中较为繁琐不好管理,通常我们需要使用Redux来帮助我们进行管理,然而随着React 16.3的发布,新context api成为了新的选择。

云栖社区 android 架构 react 性能优化 函数 Image API Consumer 面试题

咱们从头到尾讲一次 Flink 网络流控和反压剖析

文章将从网络流控的概念与背景、TCP的流控机制、Flink TCP-based 反压机制(before V1.5)、Flink Credit-based 反压机制 (since V1.5)、总结与思考等几个方面进行分享。

大数据 数据处理 TCP 网络 Consumer netty Socket network 流计算 实时计算 流控 ApacheFlink 反压机制

54
GO