最新文章列表

Kafka 0.9+Zookeeper3.4.6集群搭建、配置,新版Java Client的使用要点,高可用性测试,以及各种坑(二)

上一节中(点此传送),我们完成了Kafka集群的搭建,本节中我们将介绍0.9版本中的新API,以及Kafka集群高可用性的测试   1. 使用Kafka的Producer API来完成消息的推送   1) Kafka 0.9.0.1的java client依赖: <dependency> <groupId>org.apache.kafka</ ...
kelgon 评论(0) 有10927人浏览 2016-03-31 20:56

9学习分布式架构-KafKa介绍 Dubbo zookeeper springmvc mybatis shiro maven

核心技术:Maven,Springmvc mybatis shiro, Druid, Restful, Dubbo, ZooKeeper,Redis,FastDFS,ActiveMQ,Nginx 介绍 Kafka是一个分布式的、可分区的、可复制的消息系统。它提供了 ...
wanjee 评论(0) 有101人浏览 2016-03-31 01:25

Kafka 0.9+Zookeeper3.4.6集群搭建、配置,新版Java Client的使用要点,高可用性测试,以及各种坑(一)

Kafka 0.9版本对java client的api做出了较大调整,本文主要总结了Kafka 0.9在集群搭建、高可用性、新API方面的相关过程和细节,以及本人在安装调试过程中踩出的各种坑。   关于Kafka的结构、功能、特点、适用场景等,网上到处都是,我就不再赘述了,直接进入正文   Kafka 0.9集群安装配置   操作系统:CentOS 6.5     1. 安装J ...
kelgon 评论(0) 有3305人浏览 2016-03-30 15:44

kafka部署

kafka 集群--3个broker 3个zookeeper创建实战 准备工作: 1. 准备3台机器,IP地址分别为:192.168.0.10,192.168.0.11,192.168.0.12 2. 下载kafka稳定版本,我的版本为:kafka_2.9.2-0.8.1.1.tgz 
wuneng94zui 评论(0) 有861人浏览 2016-03-28 15:01

1学习分布式架构-介绍(Dubbo zookeeper FastDFS JMS maven springmvc mybatis shiro restful )

声明:该框架面向企业的大型互联网分布式企业架构,后期会介绍linux上部署高可用集群项目。核心技术:Maven,Springmvc mybatis shiro, Druid, Restful, Dubbo, ZooKeeper,Redis,FastDFS,ActiveMQ,Nginx 1.     项目核心代码结构截图    项目模块依赖 特别提醒:开发人员在开发的时候可以将自己的业务R ...
wanjee 评论(0) 有180人浏览 2016-03-28 01:40

(十三) Nepxion-Thunder分布式RPC集成框架 - 事件发布

Nepxion-Thunder(QQ 群 471164539)发布在https://github.com/Nepxion/  基于Google Guava EventBus,实现事件驱动发布框架内部事件,解除耦合;发布外部事件,进行重试补偿,异常通知(邮件或短信通知)  1)eventbus - 基于Google Guava的进程内发布/订阅机制,支持同步和异步事件发布2)mobile - ...
nepxion 评论(0) 有1079人浏览 2016-03-19 20:51

Logstash与Kafka集成

在ELKK的架构中,各个框架的角色分工如下: ElasticSearch1.7.2:数据存储+全文检索+聚合计算+服务端 Logstasch2.2.2:日志收集与分发推送 Kafka0.9.0.0:分布式高可靠消息队列+数据中转存储(失效期默认7天,可配置时间或大小来控制删除策略) Kibana4.1.2:全文检索+查询+图形化页面展示+客户端 拓扑架构如下: 本篇主要讲logsta ...
qindongliang1922 评论(2) 有11630人浏览 2016-02-24 18:44

Kafka主要参数详解(转)

原文档地址:http://kafka.apache.org/documentation.html ############################# System ############################# #唯一标识在集群中的ID,要求是正数。 broker.id=0 #服务端口,默认9092 port=9092 #监听地址,不设为所有地址 host.name ...
huiy 评论(0) 有1267人浏览 2016-02-24 15:35

storm、hbase、kafka整合过程中遇到的log4j冲突问题

storm、hbase、kafka整合过程中遇到的log4j冲突问题 ---》报错 SLF4J: Detected both log4j-over-slf4j.jar AND slf4j-log4j12.jar on the class path, preempting StackOverflowError. SLF4J: See also http://www.slf4j.org/codes. ...
ynp 评论(0) 有3873人浏览 2016-02-24 12:22

Kafka与Spring的集成

producer public class KafkaServiceImpl implements KafkaService { private Producer<byte[], byte[]> inner; private Properties properties; public void setInner(Producer<byte[], ...
cpjsjxy 评论(0) 有10733人浏览 2016-01-15 16:10

kafka集群安装和基本使用

kafka的集群管理是通过zookeeper实现的 第一步zookeeper启动 bin/zookeeper-server-start.sh config/zookeeper.properties  第二步kafka启动 bin/kafka-server-start.sh config/server.properties server.properties中指定zookeeper的地址 ...
蜗牛天空 评论(0) 有835人浏览 2016-01-15 13:46

kafka的本机环境搭建(二)

1.安装zk到本机。 2.安装kafka的最新版本解压到本机。 3.修改kafka的config/server.properties中的hostname为localhost. 4.启动zk. 5.启动kafka ,命令: bin/zookeeper-server-start.sh config/zookeeper.properties
不爱不见 评论(0) 有757人浏览 2016-01-15 10:20

Kafka Connect

Kafka Connect是Kafka0.9新增的模块。可以从名称看出,它可以和外部系统、数据集建立一个数据流的连接,实现数据的输入、输出。有以下特性:   使 ...
kane_xie 评论(0) 有2627人浏览 2016-01-11 15:19

KafkaTemplate的使用

<int-kafka:zookeeper-connect id="zookeeperConnect" zk-connect="${kafka.zookeeper.connect}" zk-connection-timeout="6000" zk-session-timeout="400" zk-sync-tim ...
__SuRa丶Rain 评论(0) 有6029人浏览 2016-01-02 08:47

kafka环境搭建与实战(2)kafka API实战

kafka环境搭建与实战(1)安装kafka http://zilongzilong.iteye.com/blog/2267913 kafka环境搭建与实战(2)kafka API实战 http://zilongzilong.iteye.com/blog/2267924 1.maven项目中添加依赖   <!-- kafka --> ...
zilongzilong 评论(0) 有3877人浏览 2015-12-31 17:10

kafka环境搭建与实战(1)安装kafka

kafka环境搭建与实战(1)安装kafka http://zilongzilong.iteye.com/blog/2267913 kafka环境搭建与实战(2)kafka API实战 http://zilongzilong.iteye.com/blog/2267924 1.环境介绍       3台机器IP为:                       ...
zilongzilong 评论(0) 有2329人浏览 2015-12-31 16:46

Apache kafka 介绍

kafka是一种高吞吐量的分布式发布订阅消息系统,它有如下特性:     通过O(1)的磁盘数据结构提供消息的持久化,这种结构对于即使数以TB的消息存储也能够保持长时间的稳定性能。     高吞吐量:即使是非常普通的硬件kafka也可以支持每秒数十万的消息。     支持通过kafka服务器和消费机集群来分区消息。     支持Hadoop并行数据加载。 kafka的目的是提供一个发布订阅 ...
maosheng 评论(0) 有882人浏览 2015-12-18 11:24

kafka自启动脚本

#!/bin/sh # # chkconfig: 345 99 01 # description: Kafka # # File : Kafka # # Description: Starts and stops the Kafka server # source /etc/rc.d/init.d/functions KAFKA_HOME=/opt/kafka KA ...
stevendu 评论(0) 有1326人浏览 2015-12-14 10:20

Kafka(四) -- 创建多实例集群

这一节我们看下怎么创建一个多实例的集群(以三个节点为例)。   一、 创建配置文件   进入到 Kafka 主目录,以 config/server.properties 为原型,创建 ...
bibithink 评论(0) 有3826人浏览 2015-12-08 22:42

Kafka(三) -- 安装和使用

 以下我们分五个步骤来说明 Kafka 系统的安装和使用(命令行方式)   (一)下载代码   下载链接: https://www.apache.org/dyn/closer.cgi?path=/kafka/0.9.0.0/kafka_2.11-0.9.0.0.tgz   下载后解压:   tar -xzf kafka_2.11-0.9.0.0.tgz cd kafka_ ...
bibithink 评论(0) 有1458人浏览 2015-12-08 21:11

最近博客热门TAG

Java(141747) C(73651) C++(68608) SQL(64571) C#(59609) XML(59133) HTML(59043) JavaScript(54918) .net(54785) Web(54513) 工作(54116) Linux(50906) Oracle(49876) 应用服务器(43288) Spring(40812) 编程(39454) Windows(39381) JSP(37542) MySQL(37268) 数据结构(36423)

博客人气排行榜

    博客电子书下载排行

      >>浏览更多下载

      相关资讯

      相关讨论

      Global site tag (gtag.js) - Google Analytics