首页
学习
活动
专区
工具
TVP
发布

后端技术

专栏作者
269
文章
264383
阅读量
31
订阅数
KafkaConsumer 组件源码 ConsumerCoordinator
ConsumerCoordinator继承于AbstractCoordinator,也是其唯一的实现类。AbstractCoordinator定义了有关集群协调的逻辑,定义了消费者与特定的broker(cordinator)交互的逻辑,供消费者加入消费组、探知消费组状态。
平凡的学生族
2020-07-02
6240
Kafka消费者 组件源码 Fetcher
Fetcher是与KafkaConsumer交互的各大组件之一。在各大博客上,比如某csdn博客中提到,Fetcher的作用是:
平凡的学生族
2020-06-30
9070
Spark Stream对接kafka 源码分析
本文会讲解Spark Stream是如何与Kafka进行对接的,包括DirectInputStream和KafkaRDD是如何与KafkaConsumer交互的
平凡的学生族
2020-06-29
8760
KafkaConsumer 入门理解
需要理解offset的提交机制、保存。比如commitSync、commitAsync、__consumer_offsets。 深入还能了解offset的恢复。
平凡的学生族
2020-06-28
3350
spark stream配置log输出
在cluster模式下,spark-submit添加如下参数。两个--conf分别为driver和executor设置log4j的配置文件,--files将文件上传到集群
平凡的学生族
2020-06-23
1.8K0
yarn详解
其中,在master node上运行ResourceManager。 每个datanode上运行一个NodeManager。 并把该dataNode上的所有计算资源(CPU、内存)视为一个/多个Container,而Container可以被分配执行一个task(ApplicationMaster、map task、reduce task等)。
平凡的学生族
2019-05-25
2K0
系统设计与分析 作业3
在本次项目中,我负责了调研工作,其中用到了“问卷星”这一平台。 在这个平台上可以比较轻松地设计和发布问卷,并查看统计结果。
平凡的学生族
2019-05-25
4870
hadoop3 问题大杂烩
https://blog.csdn.net/King_818/article/details/64998693 修改那个文件夹的权限
平凡的学生族
2019-05-25
4560
tomcat 请求分析(1)处理线程的创建
JIoJointPoint.startInternal创建AsyncTimeout线程:
平凡的学生族
2019-05-25
5360
netty源码解析 Future ChannelFuture
另外,它实现了Future的addListener、sync等方法,但返回值都是ChannelFuture
平凡的学生族
2019-05-25
6320
没有更多了
社区活动
Python精品学习库
代码在线跑,知识轻松学
【玩转EdgeOne】征文进行中
限时免费体验,发文即有奖~
博客搬家 | 分享价值百万资源包
自行/邀约他人一键搬运博客,速成社区影响力并领取好礼
技术创作特训营·精选知识专栏
往期视频·干货材料·成员作品·最新动态
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档