kafka1.0.0集群搭建-创新互联

一、环境准备
1、软件
zookeeper3.4.11 https://www.apache.org/dyn/closer.cgi/zookeeper/
kafka1.0.0 https://www.apache.org/dyn/closer.cgi?path=/kafka/1.0.0/kafka_2.11-1.0.0.tgz
java8 http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html
2、硬件
✔ 机器:10.205.104.55
✔ 机器:10.205.102.52
✔ 机器:10.205.105.33
二、安装
jdk安装略
1、统一目录/opt
kafka1.0.0集群搭建
2、安装zookeeper(三台机器同样操作)
cp conf/zoo_sample.cfg zoo.cfg
grep ^[^#] conf/zoo.cfg
kafka1.0.0集群搭建
添加机器id到 dataDir=/opt/zookeeper-3.4.11/data目录下的myid文件中
机器:10.205.104.55 写1
机器:10.205.102.52 写2
机器:10.205.105.33 写3
kafka1.0.0集群搭建
每台机器都是同样的配置
启动zookeeper
bin/zkServer.sh start
检验
kafka1.0.0集群搭建
3、安装kafka(每台机器broker.id不同。这里依此是0,1,2)
每台机器依此配置
kafka1.0.0集群搭建
启动kafka(每台都启动)
bin/kafka-server-start.sh config/server-1.properties &
校验
kafka1.0.0集群搭建
创建topic
bin/kafka-topics.sh --create --zookeeper 10.205.104.55:2181 --replication-factor 3 --partitions 1 --topic my-replicated-topic
查看topic信息
bin/kafka-topics.sh --describe --zookeeper 10.205.104.55:2181 --topic my-replicated-topic
kafka1.0.0集群搭建
推送信息
bin/kafka-console-producer.sh --broker-list 10.205.104.55:9092 --topic my-replicated-topic
消费信息
bin/kafka-console-consumer.sh --bootstrap-server 10.205.104.55:9092 --from-beginning --topic my-replicated-topic
安装完毕
最后送上优化文章:kafka参数配置优化

站在用户的角度思考问题,与客户深入沟通,找到连江网站设计与连江网站推广的解决方案,凭借多年的经验,让设计与互联网技术结合,创造个性化、用户体验好的作品,建站类型包括:成都做网站、成都网站设计、企业官网、英文网站、手机端网站、网站推广、空间域名、虚拟主机、企业邮箱。业务覆盖连江地区。

另外有需要云服务器可以了解下创新互联scvps.cn,海内外云服务器15元起步,三天无理由+7*72小时售后在线,公司持有idc许可证,提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案,具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势,专为企业上云打造定制,能够满足用户丰富、多元化的应用场景需求。


网页标题:kafka1.0.0集群搭建-创新互联
网站URL:http://abwzjs.com/article/dppogi.html