kafka
  1. 首页
  2. kafka

AWS EC2 CentOS release 6.5 部署zookeeper、kafka、dubbo

AWSEC2CentOSrelease6.5部署zookeeper、kafka、dubbo参考：http://blog.csdn.net/yizezhong/article/details/47777625一．安装zookeeper1)下载zookeeper安装包可去官网下载，也可通过wget命令：[root@ip-172-31-46-4~]#wgethttp://apache.fayea.com

CentOS 6.7安装Kafka 0.10.1

master修改为添加保存退出slave修改为保存退出启动Kafkamasterslave最后，检验是否安装成功。使用Kafka自带的客户端检测。进入Kafka安装主目录，先启动生产者进入交互客户端模式master创建一个名为test的主题在一个终端上启动一个生产者slave在另一个终端中启动消费者，进入交互客户端在master（生产者）上，键盘输入HelloWorld!；之后在slave（消费者）上，屏幕有同样的信息输出。证明Kafka集群已经搭建成功。

Centos6.5下kafka部署安装

一）安装JDK步骤1：新建路径/usr/Java,并在其下解压jdk-7u71-linux-x64.tar.gz#mkdir-p/usr/java#tar-zxvfjdk-7u71-linux-x64.tar.gz步骤2：添加JDK到系统环境变量#vi/etc/profile新增以下内容：exportJAVA_HOME=/usr/java/jdk1.7.0_71exportPATH=$JAVA_H

SpringBoot集成Kafka 配置工具类的详细代码

spring-kafka 是基于 java版的 kafka client与spring的集成，提供了 KafkaTemplate，封装了各种方法，方便操作,它封装了apache的kafka-client,不需要再导入client依赖，这篇文章主要介绍了SpringBoot集成Kafka 配置工具类,需要的朋友可以参考下

Springboot集成kafka高级应用实战分享

这篇文章主要介绍了Springboot集成kafka高级应用实战分享，文章围绕主题展开详细的内容介绍，具有一定的参考价值，需要的小伙伴可以参考一下

Java Kafka分区发送及消费实战

本文主要介绍了Kafka分区发送及消费实战，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧

java – 如何以健壮的方式处理kafka发布失败

我正在使用Kafka,我们有一个用例来构建一个容错系统,甚至连一条消息都不会错过.所以这就是问题所在：如果由于任何原因(ZooKeeperdown,Kafkabroker等)向Kafka发布失败,我们如何能够有效地处理这些消息并在事情再次恢复后重播它们.正如我所说的那样,即使单个消息失败也无法承受.另一个用例是我们还需要在任何给定时间点知道有多少消息由于任何原因而无法发布到Kafka,例如计数器功

kafka添加安全验证配置方式

这篇文章主要介绍了kafka添加安全验证配置方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教

java – Kafka – 使用高级消费者的延迟队列实现

如果是,我将消费两次相同的消息>问题等待很长时间没有提交偏移量,例如延迟时间是24小时,将从迭代器获取下一个,睡眠24小时,进程和提交(ZK会话超时？)>ZK会话如何在没有提交新的偏移量的情况下保持活动？