Pulsar Consumer实现介绍
Pulsar-Consumer “Pulsar is a distributed pub-sub messaging platform with a very flexible messaging model and an intuitive client API.” Pulsar ...
原文：深入Pulsar Consumer的使用方式&源码分析
原文链接 使用前准备 引入依赖： PulsarClient 在尝试使用Producer和Consumer前，我们先讲一下Pulsar客户端，因为不管是Producer还是Consumer，都是依靠PulsarClient来创建的： 我们这里简单使用，只借用ServiceUrl创建客户端，其实还有很多比较重要的参数，下面稍微列举一下： ioThreads：Set the number of thre ...
2021-08-28 17:56 0 333 推荐指数：
相关推荐
Dubbo源码分析（二）：Dubbo之消费端（Consumer）
Service接口的一个方法后由于Dubbo使用javassist动态代理，会调用Invoker的Invo ...
rocketmq源码分析3-consumer消息获取
使用rocketmq的大体消息发送过程如下： 在前面已经分析过MQ的broker接收生产者客户端发过来的消息的过程，此文主要讲述订阅者获取消息的过程，或者说broker是怎样将消息传递给消费者客户端的，即上面时序图中拉取消息(pull message)动作。。 1. 如何找到入口 ...
[源码分析] 消息队列 Kombu 之 Consumer
[源码分析] 消息队列 Kombu 之 Consumer 目录 [源码分析] 消息队列 Kombu 之 Consumer 0x00 摘要 0x01 综述功能 0x02 示例代码 0x03 定义 3.1 定义 ...
16.深入k8s：Informer使用及其源码分析
转载请声明出处哦~，本篇文章发布于luozhiyun的博客：https://www.luozhiyun.com 由于这部分的代码是在client-go 中，所以使用的源码版本是client-go 1.19 这次讲解我用了很一些图，尽可能的把这个模块给描述清楚，如果感觉对你有所 ...
深入k8s：Informer使用及其源码分析
转载 luozhiyun的博客：https://www.luozhiyun.com Informer机制# 机制设计# Informer主要有两个作用： 通过一种叫作 ListAndWa ...
dubbo源码分析三：consumer注册及生成代理对象
本章我们将分析一下consumer向注册中心注册，并获取服务端相应的信息，根据这些信息生产代理对象的过程和源码。 1.类图 上图展示了部分消费者注册及生成代理对象过程中需要使用到的类和接口，其中： spring适配涉及到的类：DubboNamespaceHandler ...
flink-connector-kafka consumer checkpoint源码分析
转发请注明原创地址：http://www.cnblogs.com/dongxiao-yang/p/7700600.html 《flink-connector-kafka consumer的topic分区分配源码》一文提到了在flink-connector-kafka的consumer ...