1,tomcat设置jvm参数设置方法:在tomcat bin 目录增加配置:setenv.sh#add tomcat pid
CATALINA_PID="$CATALINA_BASE/conf/tomcat.pid"
#add java opts
JAVA_OPTS=" -Djava.awt.headless=true -Djava.net.preferIPv4Stack=true -s...
分类:
其他好文 时间:
2014-12-30 11:51:03
阅读次数:
218
折腾了一晚,终于在Scala IDE(Eclipse加Sacla插件了)下可以看Apache Kafka工程的源代码了。
我的环境是:win7 32位,Scala IDE:4.0.0,Apache Kafka:0.8.1.1(加了一个0.8.2版本里的gradlew.bat文件)
Scala IDE下载好后,我就开始找Apache Kafka的源代码。刚开始一直用...
分类:
其他好文 时间:
2014-12-30 07:04:16
阅读次数:
1157
如何在分布式集群中,充分利用多节点,对大数据进行拆分,实现并行计算,“parallel computing by kafka-storm ” 提供了一种很好的思路。...
分类:
其他好文 时间:
2014-12-29 23:03:01
阅读次数:
208
1 应用背景: 需要实时统计用户的登陆数,在线人数,活跃时间,下载等指标的数据,或者清洗后移到hdfs上。
2 设计架构:
1) 客户端产生数据---
2) kafka-生产者实时采集数据(保留7天)-----
3) storm实时消费数据,处理数据
4)把实时数据统计结果缓存到memcached 中...
分类:
其他好文 时间:
2014-12-29 23:01:45
阅读次数:
235
由于flume-ng至1.5版本仍旧没有稳定可用的类似flume-og中的taildir的功能,所以从git中https://github.com/jinoos/flume-ng-extends找了一个别人针对flume-ng实现的的taildir这个按照github上他自己说明,是没法正常使用的。...
分类:
Web程序 时间:
2014-12-29 18:07:39
阅读次数:
219
1.topic注册信息 /brokers/topics/[topic] : 存储某个topic的partitions所有分配信息 Schema: { ? ? "version": "版本编号目前固定为数字1", ? ? "partitions": { ? ? ? ? "partitionId编号": [ ? ? ?...
分类:
Web程序 时间:
2014-12-24 16:28:20
阅读次数:
165
原文地址:http://www.aboutyun.com/thread-9938-1-1.html问题导读1.Kafka提供了Producer类作为java producer的api,此类有几种发送方式?2.总结调用producer.send方法包含哪些流程?3.Producer难以理解的在什么地方...
分类:
Web程序 时间:
2014-12-24 13:08:58
阅读次数:
189
IntroductionApache Kafkais a distributed publish-subscribe messaging system. It was originally developed at LinkedIn Corporation and later on became a...
分类:
Web程序 时间:
2014-12-23 20:47:23
阅读次数:
262
[This article was originally written by Yves Trudeau.]http://java.dzone.com/articles/exploring-message-brokersMessage brokersare not regularly covered...
分类:
其他好文 时间:
2014-12-22 14:19:03
阅读次数:
230
1.背景最近因为工作需要,调研了追求高吞吐的轻量级消息系统Kafka,打算替换掉线上运行的ActiveMQ,主要是因为明年的预算日流量有十亿,而ActiveMQ的分布式实现的很奇怪,所以希望找一个适合分布式的消息系统。以下是内容是调研过程中总结的一些知识和经验,欢迎拍砖。2.基础知识2.1.什么是消...
分类:
其他好文 时间:
2014-12-21 20:36:57
阅读次数:
290