$ sudo yum install autoconf automake libtool curl make gcc-c++ unzip cd protobuf-2.5.0 ./autogen.sh ./configure make make check make install ldconfig https://github.com/google/protobuf/release...

Apache Kafka 是目前非常具有吸引力的一个分布式消息系统, Spring 是每个 Java 开发人员耳熟能详的流行的开发框架. 这里讲介绍什么是 Spring Kafka, 如何使用 KafkaTemplate 来想 kafka brokers 产生消息, 以及如何使用 “listener container” 从 Kafka 中消费消息. 原文: Spring Kafka T...

原文: Create Multi-threaded Apache Kafka Consumer 1. 为什么需要多线程 假设我们实现了一个通知模块允许一些用户通过这个模块订阅一些来自其他用户..其他应用的通知. 我们的模块所读取的就是其他用户或应用写入到 Kafka 集群的消息. 这个例子里面, 我们将创建一个消费者订阅 Kafka 的主题来实现. 期初, 所有的事情看起来都还不错...

HBase 过滤器就是在 Get 或者 Scan 的时候过滤结果用的，可以理解为 HBase 中的 Where 语句。HBase 的过滤器会被序列化为可以在网络中传输的格式，然后分发给每个 RegionServer。在 Scan 的遍历过程中，不满足条件的结果就不会被返回个客户端。 快速入门 HBase 过滤器需要实现 Filter 接口，HBase 同时还提供了 FilterBas...

HBase 采用的是 Key/ Value 的存储方式， 这意味着，即使随着数据量增大， 也几乎不会导致查询能の下降。 HBase 并不快， 只是当数据量很大的时候它慢的不明显。 凡事都不可能只有优点而没有缺点。数据分析是 HBase 的弱项，因为对于 HBase 乃至整个 NoSQL 生态圈来说， 基本上都是不支持表关联的。 当你想实现 group by 或者 order by...

假定现在由这么一个场景：老板嗅到了市场上的一个商机，准备开启一个新项目，他将要求传达给了经理，经理根据相应的需求，来安排适合的的员工进行工作。 这个例子很简单，现在我们来模拟一下这个场景： 环境搭建 <dependency> <groupId>org.scala-lang.modules</groupId>...

参考： SpringBoot之退出服务（exit）时调用自定义的销毁方法 我们在工作中有时候可能会遇到这样场景，需要在退出容器的时候执行某些操作。Spring-Boot中有两种方法可以供我们来选择： 实现 DisposableBean 接口 使用 @PreDestroy 注解 实现 DisposableBean 接口 import org.slf4j.Logger;...

我的 HBase 的学习笔记。:lizard: Hbase 的适用场景 瞬间写入量很多， 需要长久保存 HBase 不适用 有 join ，多级索引，表关系复杂的数据模型。 CAP 定理 一致性/可用性/分区容错性 一致性：所有节点在同一时间具有相同的数据 可用性：保证每个请求不管成功或者失败都有些响应，但不保证获取的数据为正确的数据 分区...

记录一下 spring-cloud 中使用 ribbon pom.xml 需要添加的依赖： <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <...

yum（全称为 Yellow dog Updater, Modified）是一个在 Fedora 和 RedHat 以及 SUSE 中的 Shell 前端软件包管理器。基於 RPM 包管理，能够从指定的服务器自动下载 RPM 包并且安装，可以自动处理依赖性关系，并且一次安装所有依赖的软体包，无须繁琐地一次次下载、安装。yum 提供了查找、安装、删除某一个、一组甚至全部软件包的命令，而且命令简...