码迷,mamicode.com
首页 >  
搜索关键字:consumer高级特性之独有消费者(exclusive consumer)    ( 1435个结果
(一)kafka-jstorm集群实时日志分析 之 ---------kafka实时日志处理
package com.doctor.logbackextend; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Properties; import kafka.consumer.Consumer; import kafka.consumer.ConsumerCo...
分类:Web程序   时间:2014-10-26 09:07:44    阅读次数:383
华为EC169在MAC 10.9.6下的安装方法
[问题描述]华为EC169 3G上网卡需要在mbp中安装驱动。华为官网(http://consumer.huawei.com/cn/)直接搜索EC169,会发现最新的驱动也是2009年发布。下载后发现无法使用。 转而使用英文网站搜索,下载到一个2013年的通用驱动(Mobile Partner),安...
分类:系统相关   时间:2014-10-24 20:41:56    阅读次数:444
Kafka 分布式消息队列介绍
Kafka 分布式消息队列 类似产品有JBoss、MQ一、由Linkedln 开源,使用scala开发,有如下几个特点:(1)高吞吐(2)分布式(3)支持多语言客户端 (C++、Java)二、组成: 客户端是 producer 和 consumer,提供一些API,服务器端是Broker,客户端提供...
分类:其他好文   时间:2014-10-23 16:13:44    阅读次数:199
记一次消息总线的打造
虽说消息队列的用法很简单:PUB/SUB, PRODUCER/CONSUMER,不过真做起来还真麻烦。先说下原始需求:Web前端发送命令消息,后端Consumer处理,然后前端得到结果需要支持Windows服务很快,下图就出来了:先来分析分析:前端怎么知道后端已经处理完成?前端如何在处理完后的第一时...
分类:其他好文   时间:2014-10-21 23:09:23    阅读次数:198
lucene 内存索引存储每个field里内容的相关代码
相关的类调用关系DocumentsWriterPerThread ——>DocFieldProcessorDocumentsWriterPerThread里的consumer对象(类型是DocFieldProcessor)负责field的内数据的存储1 consumer.processDocumen...
分类:Web程序   时间:2014-10-21 19:05:00    阅读次数:220
[计算机故障]华为手机连接XP系统
同事新买的华为手机,拍了些照片。结果连接电脑,没有反应。后经打电话到华为,可以到华为官网下驱动。地址如下:http://consumer.huawei.com/cn/support/downloads/index.htm搜索“智能手机 usb”。下载智能手机USB驱动(Android,1.02.03...
分类:移动开发   时间:2014-10-20 17:10:56    阅读次数:479
kafka 报Failed to load class "org.slf4j.impl.StaticLoggerBinder".[z]
转:http://blog.chinaunix.net/uid-25135004-id-4172954.html测试kafka producer发送消息 和consumer 接受消息报错 ,kafka版本kafka_2.9.2-0.8.1[root@master ~]# /export/kafka/...
分类:其他好文   时间:2014-10-11 18:40:56    阅读次数:403
并发框架Disruptor浅析
1、引言 Disruptor是一个开源的Java框架,它被设计用于在生产者—消费者(producer-consumer problem,简称PCP)问题上获得尽量高的吞吐量(TPS)和尽量低的延迟。Disruptor是LMAX在线交易平台的关键组成部分,LMAX平台使用该框架对订单处理速度能达到6....
分类:其他好文   时间:2014-10-02 02:19:02    阅读次数:320
kafka入门:简介、使用场景、设计原理、主要配置及集群搭建(转)
问题导读:1.zookeeper在kafka的作用是什么?2.kafka中几乎不允许对消息进行“随机读写”的原因是什么?3.kafka集群consumer和producer状态信息是如何保存的?4.partitions设计的目的的根本原因是什么?一、入门 1、简介 Kafka is a dist.....
分类:其他好文   时间:2014-09-29 11:14:57    阅读次数:283
非分离线程使用join函数例子
/*这份代码经源码格式软件格式化过 yang_hx@neusoft.com *///非分离线程使用join函数例子:#include#include#include#include#includevoid*consumer(void*p){ static a=0 ; a...
分类:编程语言   时间:2014-09-27 00:37:28    阅读次数:260
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!