一、部署zookeeper集群
1. 准备三台服务器,IP分别为: 192.168.86.130,192.168.86.131,192.168.86.132.
2.下载zookeeper压缩包,解压,在conf目录下增加zoo.cfg文件,文件内容可参考zoo_sample.cfg. 具体内容如下:
tickTime=2000
dataDir=/usr/local/zookeeper-3.6.2/data
clientPort=2181
initLimit=5
syncLimit=2
server.1=192.168.86.130:2888:3888
server.2=192.168.86.131:2888:3888
server.3=192.168.86.132:2888:3888
3. 分别启动三台zookeeper服务器: bin/zkServer.sh start
二、部署kafka集群。
1.kafka集群利用搭建好的zookeeper集群。
2.分别在三台机器上解压kafka的压缩包。
3.修改config/server.properties文件,增加以下容,注意有些属性在文件中已有,不能重复:
broker.id=130 #brokerId 每台机器需要设置不同的值。
offsets.topic.replication.factor=3 transaction.state.log.replication.factor=3 transaction.state.log.min.isr=2
4. 分别启动三台服务器:nohup bin/kafka-server-start.sh config/server.properties &
5. 利用JAVA客户端生产消息:
5.1 在工程的pom.xml文件中加入以下内容:
<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>2.6.0</version> </dependency>
5.2 编写生产消息的代码:
public static void main(String[] args) { Properties props = new Properties(); props.put("bootstrap.servers", "192.168.86.130:9092,192.168.86.131:9092,192.168.86.132:9092"); props.put("acks", "all"); props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer"); Producer<String, String> producer = new KafkaProducer<>(props); for (int i = 120; i < 130; i++) producer.send(new ProducerRecord<String, String>("kevin-topic-5", Integer.toString(i), Integer.toString(i))); producer.close(); }
相关推荐
kafka集群zookeeper集群整合配置 本人亲自验证
kafka(端口9091-9093)-zookeeper(端口2181-2183)集群配置
Kafka、Zookeeper集群配置Demo
zookeeper配置、集群部署 kafka配置、集群部署 Window平台下
Kafka、Zookeeper集群配置Demo
centos7下Redis哨兵集群和kafka集群和zookeeper集群搭建 http://blog.csdn.net/gaowenhui2008/article/details/71516901 https://cwiki.apache.org/confluence/display/KAFKA/Clients
kafka+zookeeper高可用集群搭建shell使用脚本,直接在linux运行就行
kafka_2.12-2.2.1.tgz zookeeper-3.4.14.tar.gz
zookeeper升级方案,线上环境实战,新老版本切换。由于公司内部zookeeper集群系统版本较低,对于一些特性的支持上有点欠缺,于是决定进行对zookeeper进行升级操作。从3.3.4升级至3.4.8。
kafka集群类型: single broker(单节点单boker集群,亦即kafka只启一个broker消息中间件服务,producer、consumer、broker均通过zookeeper集群交换消息,具体可参考:http://exp-blog.com/2018/08/03/pid-2187/
zookeeper集群部署,kafka集群部署,kafka介绍,topic创建、删除、kafka监控
NULL 博文链接:https://xnbhnly.iteye.com/blog/2431757
kafka集群 zookeeper集群 配置文件
kafka+zookeeper集群安装详细教程,有需要的可以下载,并实际操作一下。
redis zookeeper kafka集群安装手册
zookeeper linux 搭建流程,zookeeper linux 搭建流程zookeeper linux 搭建流程zookeeper linux 搭建流程。
centos7下kafka和zookeeper和Redis集群搭建
redis5 cluster zookeeper集群 kafka集群安装部署手册
包好zk集群部署、kafka集群部署、kafka/zk的注册服务,开机启动设置。自己搭建总结的文档,照着做就能搭成功。