elasticSearch node 的配置如下:# Every node can be configured to allow or deny being eligible as the master,# and to allow or deny to store the data.## Allo...
分类:
其他好文 时间:
2014-07-16 21:53:05
阅读次数:
257
本文为官方文档的译文加个人理解。作者翻译时,elasticsearch(下面简称es)的版本为1.2.2。请支持原创:http://www.cnblogs.com/donlianli/p/3836768.html一、统计信息相关命令的变化有关集群状态cluster_state, 节点信息nodes_...
kafka客户端开发,如果进行多线程并行消费数据。...
分类:
编程语言 时间:
2014-07-16 17:26:29
阅读次数:
329
https://cwiki.apache.org/confluence/display/KAFKA
Pages
Index
Skip
to end of metadata
Attachments:1
Added by Alan D. Cabrera, last edited by Neha
Narkhede ...
分类:
其他好文 时间:
2014-07-15 22:25:29
阅读次数:
344
# 学习前言
框架整合中用到的所有工程代码,jar包什么的都已经上传到群214293307共享中,需要的话自己下载研究了。
# Flume的学习请参考_00016 Flume的体系结构介绍以及Flume入门案例(往HDFS上传数据)这篇博文
# Kafka的学习请参考_00017 Kafka的体系结构介绍以及Kafka入门案例(初级案例+Java API的使用)这篇博文
# Storm的学习请参考_00019 Storm的体系结构介绍以及Storm入门案例(官网上的简单Java案例)这篇博文
请学习...
分类:
其他好文 时间:
2014-07-14 18:32:41
阅读次数:
574
请支持原创:http://www.cnblogs.com/donlianli/p/3841762.html1、索引格式1.x之前的版本,被索引的文档type会同时出现在url和传输的数据格式中,如下:PUT /my_index/my_type/1{ "my_type": { ... doc fie....
在lucene里面,suggest 的支持非常完善,可以随心所欲的定制;但是在es中使用起来就没有那么方便了。es给suggest 分类4类:term ;phrase; completion; context;目前最新版本是es1.2.1 这一块也还在不断完善中;[term suggester](....
分类:
其他好文 时间:
2014-07-13 13:04:41
阅读次数:
1433
Consumer API有两个级别。低级别的和一个指定的broker保持连接,并在接收完消息后关闭连接,这个级别是无状态的,每次读取消息都带着offset。
高级别的API隐藏了和brokers连接的细节,在不必关心服务端架构的情况下和服务端通信。还可以自己维护消费状态,并可以通过一些条件指定订阅特定的topic,比如白名单黑名单或者正则表达式。...
Kafka是一个分布式的、可分区的、可复制的消息系统。它提供了普通消息系统的功能,但具有自己独特的设计。这个独特的设计是什么样的呢?
首先让我们看几个基本的消息系统术语:
Kafka将消息以topic为单位进行归纳。
将向Kafka topic发布消息的程序成为producers.
将预订topics并消费消息的程序成为consumers.
Kafka以集群的方式运行,可以由一个或多个服务组成,每个服务叫做一个broker....
分类:
其他好文 时间:
2014-07-11 00:01:24
阅读次数:
197
一、整体看一下Kafka
我们知道,Kafka系统有三大组件:Producer、Consumer、broker 。
producers 生产消息并推(push)送给brokers,consumers从brokers把消息提取(pull)出来。
二、开发一个Producer应用
Producers用来生产消息并把产生的消息推送到Kafka...
分类:
其他好文 时间:
2014-07-10 23:07:37
阅读次数:
263