Kafka集群配置比较简单,为了更好的让大家理解,在这里要分别介绍下面三种配置
单节点:一个broker的集群单节点:多个broker的集群多节点:多broker集群
一、单节点单broker实例的配置
1.首先启动zookeeper服务
Kafka提供了一个简单的zookeeper配置文件来帮助启动zookeeper实例,用下面这个命令即可,首先进入Kafka的安装...
分类:
其他好文 时间:
2014-07-31 20:59:27
阅读次数:
334
一、关于本文 本文中实现的PCHelper类是一个简易的Producer-Consumer操作工具类。该类可以实现如下目标:由多个线程向其中的一个Queue中写入数据,同时由多个线程负责接收Queue中数据进行处理。 二、工具类代码 ...
分类:
其他好文 时间:
2014-07-29 18:27:32
阅读次数:
252
当从webservice接收到信息的时候,消息生产者producer立刻把收到的消息放入到jms里面,消费者cusomer这时要设置一个监听,当生产者发送消息时,只要消息被发出来,消费者就会接收到消息,然后进行相应的操作。在tomcat里面,要进行配置。首先在tomcat安装目录里面,对conf/c...
分类:
其他好文 时间:
2014-07-25 14:23:41
阅读次数:
280
阅读背景:您需要对Zk,Kafka有基础的了解 ? ? ?本章主题:详尽的梳理ZkCoordinator的过程 package?com.mixbox.storm.kafka;
import?org.slf4j.Logger;
import?org.slf4j.LoggerFactory;
import?...
分类:
其他好文 时间:
2014-07-23 14:00:16
阅读次数:
343
前言: kafka是linkedin开源的消息队列, 淘宝的metaq就是基于kafka而研发. 而消息队列作为一个分布式组件, 在服务解耦/异步化, 扮演非常重要的角色. 本系列主要研究kafka的思想和使用, 本文主要讲解kafka的一些基本概念和api的使用. *) 准备工作1) 配置ma.....
介绍略 集群安装: 一.准备工作: 1.版本介绍: 目前我们使用版本为kafka_2.9.2-0.8.1(scala-2.9.2为kafka官方推荐版本,此外还有2.8.2和2.10.2可以选择) 2.环境准备: 安装JDK6,目前使用版本为1.6,并配置JAV...
分类:
其他好文 时间:
2014-07-21 10:25:51
阅读次数:
173
1. 设计好一组分类信息;2. 在列表页模板中填写帖子的标题格式,例如:[{producer_value}][{artist_value}]{subject}[{size_value}{size_unit}]3. 修改template\default\forum\forumdisplay_list....
分类:
其他好文 时间:
2014-07-19 00:15:50
阅读次数:
407
# Kafka 高级部分之自定义Encoder实现Class级别的数据传送已经解析
# 前言
本博文中用到的所有工程代码,jar包什么的都已经上传到群214293307共享中,需要的话自己下载研究了。
本博文《_00023 Kafka 诡异操作_001自定义Encoder实现Class级别的数据传送以及解析》中的Eclipse工程代码下载地址 http://download.csdn.net/detail/u012185296/7633405
# Class级别信息Send的原理
简单的说就是将一个...
分类:
其他好文 时间:
2014-07-18 12:31:58
阅读次数:
527
多线程设计模式第1章 Single Threaded Execution——能通过这座桥的,只有一个人第2章 Immutable——想破坏它也没办法第3章 Guarded Suspension——要等到我准备好喔第4章 Balking——不需要的话,就算了吧第5章 Producer-Consumer...
分类:
编程语言 时间:
2014-07-18 11:38:30
阅读次数:
231