1、在使用Java API访问之前先在安装有kafka的各个节点启动服务
bin/kafka-server-start.sh config/server.properties &
2、报如下错误
props.put("metadata.broker.list", "storm1:9092,storm2:9092,storm3:9092");
props.put("serializer.cl...
分类:
其他好文 时间:
2015-02-07 18:56:33
阅读次数:
174
kafka是用scala编写,用zookeeper做协调。scala的代码没学习过,这边主要看别人写的文档和自己的工作实践来的。笔记可能会写多篇,因为这东西要经常看啊,不看过了多久就忘了。
东西看完了就要问问自己3W1H
What:kafka是一个分布式(多broker,zookeeper)的,分区的(partition),消息复制的(replicate)的消息中间件(log service)...
分类:
其他好文 时间:
2015-02-05 18:32:14
阅读次数:
211
KAFKA学习总结 一、?简介 KAFKA是Apache基金会的一个开源项目,是一个分布式的发布-订阅的消息系统; KAFKA用途广泛,可以用作消息队列,也可以用作日志系统,还有其他一些应用,在此不作详细介绍; 二、?组成 按照不同...
分类:
其他好文 时间:
2015-02-03 11:24:22
阅读次数:
257
第一天1、编程语言介绍2、Python基础,介绍历史、发展情况及现状3、Python安装、环境准备4、编程风格、语法要求、变量格式等5、编写用户交互脚本6、读取用户输入7、基本流程控制,if..else/for x in…/while True8、程序流程控制二,break\continue\ 嵌套...
分类:
编程语言 时间:
2015-02-02 19:39:42
阅读次数:
367
一、基础介绍。1:文件的构成。 1,首先声明,这里的文件和目录,仅仅表示普通的文件和目录。不代表设备,管道等特殊形式的文件(UNIX把它们也当作文件处理)。 2,目录的构成:v节点编号和文件名。 1)v节点:文件系统相关的节点。文件类型,各类文件操作函数指针。但目录中包含的是节点编号,不是...
分类:
系统相关 时间:
2015-02-02 17:43:47
阅读次数:
262
场景:使用Spark Streaming接收Kafka发送过来的数据与关系型数据库中的表进行相关的查询操作;Kafka发送过来的数据格式为:id、name、cityId,分隔符为tab1 zhangsan 12 lisi 13 wangwu ...
分类:
数据库 时间:
2015-02-02 10:48:27
阅读次数:
169
Kafka设计的初衷是迅速处理短小的消息,一般10K大小的消息吞吐性能最好(可参见LinkedIn的kafka性能测试)。但有时候,我们需要处理更大的消息,比如XML文档或JSON内容,一个消息差不多有10-100M,这种情况下,Kakfa应该如何处理?针对这个问题,有以下几个建议: 最好的方法是不...
分类:
其他好文 时间:
2015-02-01 00:38:26
阅读次数:
17815
chtml标签是WebEasy标签语言的开始和结束符,WebEasy在分析一个完整的html、xml或SVG文件时,只对到或到之间的标签进行解释执行,其他内容就当静态(html、xml)文本处理后直接输出到浏览器。这样就大大提高了服务器的响应速度,几乎可以达到直接访问静态页面的响应速度,而且不要求整个页面内容写得很规范和严密...
分类:
Web程序 时间:
2015-01-29 09:24:53
阅读次数:
186
注:由于别人写的太好了就转来基础介绍!转自:http://www.infoq.com/cn/articles/docker-core-technology-previewDocker是PaaS供应商dotCloud开源的一个基于LXC 的高级容器引擎,源代码托管在 GitHub 上, 基于Go语言开...
分类:
其他好文 时间:
2015-01-28 17:18:24
阅读次数:
168