转载自http://blog.chinaunix.net/uid-20196318-id-2420884.htmlKafka[1]是linkedin用于日志处理的分布式消息队列,linkedin的日志数据容量大,但对可靠性要求不高,其日志数据主要包括用户行为(登录、浏览、点击、分享、喜欢)以及系统运...
分类:
其他好文 时间:
2015-08-17 11:44:06
阅读次数:
105
转自:http://blog.csdn.net/honglei915/article/details/37564521原文地址:http://blog.csdn.net/honglei915/article/details/37564521介绍Kafka是一个分布式的、可分区的、可复制的消息系统。它...
分类:
其他好文 时间:
2015-08-16 18:16:02
阅读次数:
110
1.kafka是一种高吞吐量的分布式发布订阅消息系统,它可以处理消费者规模的网站中的所有动作流数据
Step 1: Download the code
Download the
0.8.2.0 release and un-tar it.
> tar -xzf kafka_2.10-0.8.2.0.tgz
> cd kafka_2.10-0.8.2.0
Ste...
分类:
其他好文 时间:
2015-08-16 12:23:45
阅读次数:
179
http://www.aboutyun.com/thread-6855-1-1.html个人观点:大数据我们都知道hadoop,但并不都是hadoop.我们该如何构建大数据库项目。对于离线处理,hadoop还是比较适合的,但是对于实 时性比较强的,数据量比较大的,我们可以采用Storm,那么Stor...
分类:
Web程序 时间:
2015-08-14 11:27:12
阅读次数:
220
KAFKA分布式消息系统 2011-08-28 18:32:46分类: LINUXKafka[1]是linkedin用于日志处理的分布式消息队列,linkedin的日志数据容量大,但对可靠性要求不高,其日志数据主要包括用户行为(登录、浏览、点击、分享、喜欢)以及系统运行日志(CPU、内存、磁盘、网络...
分类:
其他好文 时间:
2015-08-14 11:08:43
阅读次数:
146
1.概述 本课程的视频教程地址:《Kafka实战项目之应用概述》 本课程是通过一个用户实时上报日志来展开的,通过介绍 Kafka 的业务和应用场景,并带着大家搭建本 Kafka 项目的实战开发环境。下面我们来看看本课程有哪些课时,如下图所示: 接下来,我们开始第一课时的学习:《Kafka 回顾...
分类:
其他好文 时间:
2015-08-13 13:54:04
阅读次数:
209
转载自http://www.tuicool.com/articles/NzyqAn在基于Hadoop平台的很多应用场景中,我们需要对数据进行离线和实时分析,离线分析可以很容易地借助于Hive来实现统计分析,但是对于实时的需求Hive就不合适了。实时应用场景可以使用Storm,它是一个实时处理系统,它...
分类:
其他好文 时间:
2015-08-12 18:18:39
阅读次数:
134
我们继续讨论console consumer的实现原理,本篇着重探讨ZookeeperConsumerConnector的使用,即后续所有的内容都由下面这条语句而起:val connector = Consumer.create(config)那么问题来了?这条语句后面执行了什么呢?我们先看crea...
分类:
其他好文 时间:
2015-08-11 22:58:11
阅读次数:
892
kafka分区及副本在broker的分配部分内容参考自:http://blog.csdn.net/lizhitao/article/details/41778193下面以一个Kafka集群中4个Broker举例,创建1个topic包含4个Partition,2 Replication;数据Producer流动如图所示:
(1)
pic(2)当集群中新增2节点,Partition增加到6个时分布情...
分类:
其他好文 时间:
2015-08-11 18:56:59
阅读次数:
169
最近 有网友看我的“整合Kafka到Spark Streaming——代码示例和挑战”文章,
讲 kafka对象 放到 pool 并通过broadcast广播出去:
然后 在开发测试阶段 报错如下:
然后就找我,说“代码都跟你的差不多呀,为什么就报这个错呢?”
其实 对于广播操作,spark 肯定要序列号的,还有尽量不要把大对象广播出去,
后来 把代码要过来看了下,发现 creat...
分类:
编程语言 时间:
2015-08-11 16:14:24
阅读次数:
173