Java?客户端连接Kafka报如下错误 bin/kafka-console-consumer.sh?--zookeeper?255.255.255.255:2181?--topic?eventbustopic
[2015-06-02?16:23:04,375]?WARN?Fetching?topic?metadata?with?correlati...
分类：
编程语言 时间：
2015-10-28 12:56:08
阅读次数：
740
在broker的配置中，auto.leader.rebalance.enable (false) 那么这个leader是如何进行rebalance的？ 首先在controller启动的时候会打开一个scheduler， if (config.autoLeaderRebalanceEnable) { ...
分类：
Web程序 时间：
2015-10-27 13:07:08
阅读次数：
292
kafka apis反映出kafka broker server可以提供哪些服务，broker server主要和producer，consumer，controller有交互，搞清这些api就清楚了broker server的所有行为 handleOffsetRequest 提供对offset的查...
之前写了收集linux系统历史history命令，下面介绍一下系统里日志收集与展示的。老规矩，先看效果，满意的话继续看。一、效果图1、总览2、linux系统日志收集数据总量主要是展示所选范围内容收集日志总量3、linux系统日志收集主机数主要是展示当前总共有多少台主机上传了message..
分类：
系统相关 时间：
2015-10-26 10:31:26
阅读次数：
327
1.Kafka入门经典教程： http://www.aboutyun.com/thread-12882-1-1.html2.分布式服务框架 Zookeeper -- 管理分布式环境中的数据 https://www.ibm.com/developerworks/cn/opensource/os-cn-...
分类：
其他好文 时间：
2015-10-25 11:59:26
阅读次数：
141
在大数据时代，数据规模变得越来越大。由于数据的增长速度和非结构化的特性，常用的软硬件工具已无法在用户可容忍的时间内对数据进行采集、管理 和处理。本文主要介绍如何在阿里云上使用Kafka和Storm搭建大规模消息分发和实时数据流处理系统，以及这个过程中主要遭遇的一些挑战。实践主要立 足建立一套汽车状态...
分类：
其他好文 时间：
2015-10-22 20:55:26
阅读次数：
259
问题导读：1.zookeeper在kafka的作用是什么？2.kafka中几乎不允许对消息进行“随机读写”的原因是什么？3.kafka集群consumer和producer状态信息是如何保存的？4.partitions设计的目的的根本原因是什么？一、入门 1、简介 Kafka is a dist.....
分类：
其他好文 时间：
2015-10-22 12:15:25
阅读次数：
163
<?phperror_reporting(E_ALL&~E_NOTICE);define(‘ELK_QUERY_RR_QUERY‘,‘{"query":{"filtered":{"query":{"query_string":{"analyze_wildcard":true,"query":"type:phptestkvANDreport_type:\"passport.codecreate\""}},"filter":{"bool":{"must":[{"range":{"@timestamp..
分类：
Web程序 时间：
2015-10-22 06:55:19
阅读次数：
173
<?phperror_reporting(E_ALL&~E_NOTICE);define(‘ELK_QUERY_RR_QUERY‘,‘{"query":{"filtered":{"query":{"query_string":{"analyze_wildcard":true,"query":"type:phptestkvANDreport_type:\"paycenter.dopayment\""}},"filter":{"bool":{"must":[{"range":{"@timestamp..
分类：
Web程序 时间：
2015-10-22 06:54:14
阅读次数：
165
<?phperror_reporting(E_ALL&~E_NOTICE);define(‘ELK_QUERY_RR_QUERY‘,‘{"query":{"filtered":{"query":{"query_string":{"analyze_wildcard":true,"query":"type:phptestkvANDreport_type:\"cart.add\""}},"filter":{"bool":{"must":[{"range":{"@timestamp":{"gte":"n..
分类：
Web程序 时间：
2015-10-22 06:53:42
阅读次数：
149
