1.topic注册信息/brokers/topics/[topic] :存储某个topic的partitions所有分配信息Schema:{ "version": "版本编号目前固定为数字1", "partitions": { "partitionId编号": [ 同步副本组br...
分类：
其他好文 时间：
2015-07-07 12:47:49
阅读次数：
209
1：kafka-topics.sh（如果没有返回信息，说明命令无效）创建一个top名字：gbz4，zookeeper地址：本机，两个分区，两个副本./bin/kafka-topics.sh -create --topic 'gbz4' --zookeeper '127.0.0.1' --partit...
分类：
其他好文 时间：
2015-07-07 12:25:30
阅读次数：
147
=================this指针的由来==================== 一个学生可以有多本书一样，而这些书都是属于这个同学的；同理，如果有很多个同学在一起，那么为了确定他们的书不要拿混淆了，最好的办法我想应该就是每个同学都在自己的书上写上名字，这样肯定就不会拿错了。 同理，一个...
分类：
其他好文 时间：
2015-07-05 13:38:25
阅读次数：
116
一个、整体外观Kafka我们知道。Kafka系统有三大组件：Producer、Consumer、broker 。producers 生产(produce)消息(message)并推(push)送给brokers，consumers从brokers把消息提取(pull)出来消费(consume)。二、...
分类：
其他好文 时间：
2015-07-05 09:28:08
阅读次数：
158
Pinot 是一个实时分布式的 OLAP 数据存储和分析系统。LinkedIn 使用它实现低延迟可伸缩的实时分析。Pinot 从离线数据源（包括 Hadoop 和各类文件）和在线数据源（如 Kafka）中攫取数据进行分析。Pinot 被设计是可以进行水平扩展的。...
分类：
其他好文 时间：
2015-07-03 17:35:04
阅读次数：
284
kafka集群搭建与api客户端创建，以前的消息队列（activeMQ）对于大数据吞吐率不行，但kafka很好的解决了此类问题，并且以集群的方式进行扩展，可谓相当强大...
package com.doctor.logbackextend;import java.util.HashMap;import java.util.List;import java.util.Map;import java.util.Properties;import kafka.consumer...
分类：
Web程序 时间：
2015-07-01 20:32:42
阅读次数：
174
Kafka 是分布式发布-订阅消息系统。它最初由 LinkedIn 公司开发，之后成为 Apache 项目的一部分。Kafka 是一个分布式的，可划分的，冗余备份的持久性的日志服务。它主要用于处理活跃的流式数据。在大数据系统中，常常会碰到一个问题，整个大数据是由各个子系统组成，数据需要在各个子系统中...
分类：
其他好文 时间：
2015-06-30 17:47:57
阅读次数：
121
Hadoop原理 分为HDFS与Yarn两个部分。HDFS有Namenode和Datanode两个部分。每个节点占用一个电脑。Datanode定时向Namenode发送心跳包，心跳包中包含Datanode的校验等信息，用来监控Datanode。HDFS将数据分为块，默认为64M每个块信息按照配置的参...
分类：
其他好文 时间：
2015-06-30 12:29:40
阅读次数：
221
在开发过程中绝大多数时间使用的是UIKit和Foundation框架，UIKit提供诸如UIView和UIButton这类的控件，Foundation提供NSArray,NSDictionary这类的数据结构，两者结合可以解决大部分问题，但是有的时候需要底层框架，底层框架名字通常以Core开头，比如...
分类：
其他好文 时间：
2015-06-29 13:13:50
阅读次数：
104
