【原创】kafka consumer源代码分析
顾名思义，就是kafka的consumer api包。 一、ConsumerConfig.scala Kafka consumer的配置类，除了一些默认值常量及验证参数的方法之外，就是consumer的配置参数了，比如group.id, consumer.id等，详细列表见官网 ...
原文：【原创】Kakfa message包源代码分析
笔者最近在研究Kafka的message包代码，有了一些心得，特此记录一下。其实研究的目的从来都不是只是看源代码，更多地是想借这个机会思考几个问题：为什么是这么实现的 你自己实现方式是什么 比起人家的实现方式，你的方案有哪些优缺点 任何消息引擎系统最重要的都是定义消息，使用什么数据结构来保存消息和消息队列 刚刚思考这个问题的时候，我自己尝试实现了一下Message的定义： 可以看出，实现的方式是 ...
2015-03-29 17:08 0 1957 推荐指数：
相关推荐
【原创】Kafka console consumer源代码分析(一)
上一篇中分析了Scala版的console producer代码，这篇文章为读者带来一篇console consumer工作原理分析的随笔。其实不论是哪个consumer，大部分的工作原理都是类似的。本文利用console consumer作为切入点，既容易理解又不失一般性 ...
hadoop源代码分析（4）-org.apache.hadoop.util包-GenericOptionsParser类【原创】
一 准备 hadoop版本：1.0.3，GenericOptionsParser所在的包：org.apache.hadoop.util 学习方法：理解GenericOptionsParser这个解析器的使用地方，从构造函数入手，理解GenericOptionsParser整个类 ...
mybatis源代码分析之binding包
在使用ibatis执行数据库访问时，会调用形如 这样的代码。这样的形式要求调用方选择需要使用的函数（queryForObject、queryForList、update），还需要告诉这个函数具体执行哪一个statement（上文中是“getCityByCityId”），在这个过程中 ...
Mybatis源代码分析之metadata包
数据库中我们最常用到的元素就是database、table、column。Mybatis作为强大的ORM框架，当中也包含了获取处理这些元素的代码，本篇将介绍相关的内容。 一、Catalog & Schema 在介绍具体的代码实现之前，我们需要先了解两个 ...
Mybatis源代码分析之parsing包
parsing，从字面上理解就是编译解析的意思，那么这个包中的内容就应该和mybatis配置文件的编译解析有关系。本文首先会按照引用层次来分别介绍这个包中各个类的作用，而后再用实际的例子解释它们是如何组合到一起去解决了什么样的问题。 一、类和接口介绍 1.TokenHandler ...
【原创】k8s源代码分析-----kubelet（1）主要流程
本人空间链接http://user.qzone.qq.com/29185807/blog/1460015727 源代码为k8s v1.1.1稳定版本号 kubelet代码比較复杂 ...
mybatis $和#源代码分析
JDBC中，主要使用两种语句，一种是支持参数化和预编译的PreparedStatement,支持原生sql,支持设置占位符，参数化输入的参数，防止sql注入攻击，在mybatis的mapper配置文件 ...