HBase 1.2.0源码系列：HBase RPC 通信（上）
HBase 中 HMaster、HRegionServer 和 Client 之间的通信使用了两个技术，Goo […]
Kafka 通信协议（译）
原文链接 A Guide To The Kafka Protocol Kafka 的 Producer、Bro […]
Kafka 消息持久化
持久化原理 Kakfa 依赖文件系统来存储和缓存消息。对于硬盘的传统观念是硬盘总是很慢，基于文件系统的架构能否 […]
Kafka 消费者 Java 实现
应用程序使用 KafkaConsumer向 Kafka 订阅 Topic 接收消息，首先理解 Kafka 中消 […]
Kafka 生产者 Java 实现
创建生产者 向 Kafka 写入消息，首先要创建一个生产者对象，该对象有3个必要属性。 bootstrap.s […]
Apache Griffin 简介
参考资料 https://www.iteblog.com/archives/2492.html http:// […]
Kafka 入门介绍
Kafka 最初由 Linkedin 公司开发，是一个分布式、支持分区的（partition）、多副本的（re […]
Flink 指标（二）
报告（Reporter） 通过 conf/flink-conf.yaml 文件配置一个或多个 Reporter […]