本月博客排行
-
第1名
龙儿筝 -
第2名
lerf -
第3名
fantaxy025025 - johnsmith9th
- zysnba
- xiangjie88
年度博客排行
-
第1名
青否云后端云 -
第2名
宏天软件 -
第3名
gashero - wy_19921005
- vipbooks
- benladeng5225
- e_e
- wallimn
- javashop
- ranbuijj
- fantaxy025025
- jickcai
- gengyun12
- zw7534313
- qepwqnp
- 解宜然
- ssydxa219
- zysnba
- sichunli_030
- sam123456gz
- arpenker
- tanling8334
- gaojingsong
- kaizi1992
- xpenxpen
- 龙儿筝
- jh108020
- wiseboyloves
- ganxueyun
- xyuma
- xiangjie88
- wangchen.ily
- Jameslyy
- luxurioust
- lemonhandsome
- mengjichen
- jbosscn
- zxq_2017
- lzyfn123
- nychen2000
- forestqqqq
- wjianwei666
- ajinn
- zhanjia
- Xeden
- hanbaohong
- java-007
- 喧嚣求静
- mwhgJava
- kingwell.leng
最新文章列表
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</ ...
9学习分布式架构-KafKa介绍 Dubbo zookeeper springmvc mybatis shiro maven
核心技术:Maven,Springmvc mybatis shiro, Druid, Restful, Dubbo, ZooKeeper,Redis,FastDFS,ActiveMQ,Nginx 介绍
Kafka是一个分布式的、可分区的、可复制的消息系统。它提供了 ...
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 ...
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
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 ...
(十三) Nepxion-Thunder分布式RPC集成框架 - 事件发布
Nepxion-Thunder(QQ 群 471164539)发布在https://github.com/Nepxion/
基于Google Guava EventBus,实现事件驱动发布框架内部事件,解除耦合;发布外部事件,进行重试补偿,异常通知(邮件或短信通知)
1)eventbus - 基于Google Guava的进程内发布/订阅机制,支持同步和异步事件发布2)mobile - ...
Logstash与Kafka集成
在ELKK的架构中,各个框架的角色分工如下:
ElasticSearch1.7.2:数据存储+全文检索+聚合计算+服务端
Logstasch2.2.2:日志收集与分发推送
Kafka0.9.0.0:分布式高可靠消息队列+数据中转存储(失效期默认7天,可配置时间或大小来控制删除策略)
Kibana4.1.2:全文检索+查询+图形化页面展示+客户端
拓扑架构如下:
本篇主要讲logsta ...
Kafka主要参数详解(转)
原文档地址:http://kafka.apache.org/documentation.html
############################# System #############################
#唯一标识在集群中的ID,要求是正数。
broker.id=0
#服务端口,默认9092
port=9092
#监听地址,不设为所有地址
host.name ...
kafka集群安装和基本使用
kafka的集群管理是通过zookeeper实现的
第一步zookeeper启动
bin/zookeeper-server-start.sh config/zookeeper.properties
第二步kafka启动
bin/kafka-server-start.sh config/server.properties
server.properties中指定zookeeper的地址 ...
kafka的本机环境搭建(二)
1.安装zk到本机。
2.安装kafka的最新版本解压到本机。
3.修改kafka的config/server.properties中的hostname为localhost.
4.启动zk.
5.启动kafka ,命令: bin/zookeeper-server-start.sh config/zookeeper.properties
KafkaTemplate的使用
<int-kafka:zookeeper-connect id="zookeeperConnect" zk-connect="${kafka.zookeeper.connect}" zk-connection-timeout="6000" zk-session-timeout="400" zk-sync-tim ...
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 -->
...
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为:
...
Apache kafka 介绍
kafka是一种高吞吐量的分布式发布订阅消息系统,它有如下特性:
通过O(1)的磁盘数据结构提供消息的持久化,这种结构对于即使数以TB的消息存储也能够保持长时间的稳定性能。
高吞吐量:即使是非常普通的硬件kafka也可以支持每秒数十万的消息。
支持通过kafka服务器和消费机集群来分区消息。
支持Hadoop并行数据加载。
kafka的目的是提供一个发布订阅 ...