码迷,mamicode.com
首页 >  
搜索关键字:kafka    ( 4273个结果
[转载] KAFKA分布式消息系统
转载自http://blog.chinaunix.net/uid-20196318-id-2420884.htmlKafka[1]是linkedin用于日志处理的分布式消息队列,linkedin的日志数据容量大,但对可靠性要求不高,其日志数据主要包括用户行为(登录、浏览、点击、分享、喜欢)以及系统运...
分类:其他好文   时间:2015-08-17 11:44:06    阅读次数:105
(转)漫游Kafka入门篇之简单介绍
转自:http://blog.csdn.net/honglei915/article/details/37564521原文地址:http://blog.csdn.net/honglei915/article/details/37564521介绍Kafka是一个分布式的、可分区的、可复制的消息系统。它...
分类:其他好文   时间:2015-08-16 18:16:02    阅读次数:110
【大数据架构】3. kafka安装与使用
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
大数据架构:flume-ng+Kafka+Storm+HDFS 实时系统组合
http://www.aboutyun.com/thread-6855-1-1.html个人观点:大数据我们都知道hadoop,但并不都是hadoop.我们该如何构建大数据库项目。对于离线处理,hadoop还是比较适合的,但是对于实 时性比较强的,数据量比较大的,我们可以采用Storm,那么Stor...
分类:Web程序   时间:2015-08-14 11:27:12    阅读次数:220
KAFKA分布式消息系统
KAFKA分布式消息系统 2011-08-28 18:32:46分类: LINUXKafka[1]是linkedin用于日志处理的分布式消息队列,linkedin的日志数据容量大,但对可靠性要求不高,其日志数据主要包括用户行为(登录、浏览、点击、分享、喜欢)以及系统运行日志(CPU、内存、磁盘、网络...
分类:其他好文   时间:2015-08-14 11:08:43    阅读次数:146
Kafka项目实战-用户日志上报实时统计之应用概述
1.概述 本课程的视频教程地址:《Kafka实战项目之应用概述》 本课程是通过一个用户实时上报日志来展开的,通过介绍 Kafka 的业务和应用场景,并带着大家搭建本 Kafka 项目的实战开发环境。下面我们来看看本课程有哪些课时,如下图所示: 接下来,我们开始第一课时的学习:《Kafka 回顾...
分类:其他好文   时间:2015-08-13 13:54:04    阅读次数:209
[转载] Kafka+Storm+HDFS整合实践
转载自http://www.tuicool.com/articles/NzyqAn在基于Hadoop平台的很多应用场景中,我们需要对数据进行离线和实时分析,离线分析可以很容易地借助于Hive来实现统计分析,但是对于实时的需求Hive就不合适了。实时应用场景可以使用Storm,它是一个实时处理系统,它...
分类:其他好文   时间:2015-08-12 18:18:39    阅读次数:134
【原创】Kafka console consumer源代码分析(二)
我们继续讨论console consumer的实现原理,本篇着重探讨ZookeeperConsumerConnector的使用,即后续所有的内容都由下面这条语句而起:val connector = Consumer.create(config)那么问题来了?这条语句后面执行了什么呢?我们先看crea...
分类:其他好文   时间:2015-08-11 22:58:11    阅读次数:892
kafka分区及副本在broker的分配
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
com.esotericsoftware.kryo.kryoexception java.util.ConcurentModificationException
最近 有网友看我的“整合Kafka到Spark Streaming——代码示例和挑战”文章, 讲 kafka对象 放到 pool 并通过broadcast广播出去: 然后 在开发测试阶段 报错如下: 然后就找我,说“代码都跟你的差不多呀,为什么就报这个错呢?” 其实 对于广播操作,spark 肯定要序列号的,还有尽量不要把大对象广播出去, 后来 把代码要过来看了下,发现 creat...
分类:编程语言   时间:2015-08-11 16:14:24    阅读次数:173
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!