kafka集群安装(独立zookeeper集群)
2016-11-14 18:39
369 查看
1 集群环境
192.168.100.200
192.168.100.201
192.168.100.202
2 按照步骤
[root@localhost local]# tar -zxvf kafka_2.11-0.10.1.0.tgz
[root@localhost local]# cd kafka_2.11-0.10.1.0/
[root@localhost kafka_2.11-0.10.1.0]# mkdir logs
[root@localhost kafka_2.11-0.10.1.0]# cd config/
[root@localhost config]# vi server.properties
broker.id=0
listeners=PLAINTEXT://192.168.100.200:9092
advertised.listeners=PLAINTEXT://192.168.100.200:9092
log.dirs=/usr/local/kafka_2.11-0.10.1.0/logs/
zookeeper.connect=192.168.100.200:2181,192.168.100.201:2181,192.168.100.202:2181
[root@localhost local]# scp -r /usr/local/kafka_2.11-0.10.1.0 192.168.100.201:/usr/local/
[root@localhost local]# scp -r /usr/local/kafka_2.11-0.10.1.0 192.168.100.202:/usr/local/
在其它两个节点上修改
broker.id=1
listeners=PLAINTEXT://192.168.100.201:9092
advertised.listeners=PLAINTEXT://192.168.100.201:9092
broker.id=2
listeners=PLAINTEXT://192.168.100.202:9092
advertised.listeners=PLAINTEXT://192.168.100.202:9092
启动(每一个节点)
[root@localhost kafka_2.11-0.10.1.0]# bin/kafka-server-start.sh -daemon /usr/local/kafka_2.11-0.10.1.0/config/server.properties &
[root@localhost kafka_2.11-0.10.1.0]# jps
进程名为Kafka
3 验证
创建一个主题wangyl,备份3,分区2
[root@localhost kafka_2.11-0.10.1.0]# bin/kafka-topics.sh --create --topic wangyl --replication-factor 3 --partitions 2 --zookeeper 192.168.100.200:2181
查看主题
[root@localhost kafka_2.11-0.10.1.0]# bin/kafka-topics.sh --list --zookeeper 192.168.100.200:2181
生产消费模式验证
生产端
[root@localhost kafka_2.11-0.10.1.0]# bin/kafka-console-producer.sh --broker-list 192.168.100.200:9092 --sync --topic wangyl
消费端
[root@localhost kafka_2.11-0.10.1.0]# bin/kafka-console-consumer.sh --zookeeper 192.168.100.200:2181 --topic wangyl --from-beginning
列出该主题的详细信息
[root@localhost kafka_2.11-0.10.1.0]# bin/kafka-topics.sh --describe --zookeeper 192.168.100.200:2181 --topic wangyl
192.168.100.200
192.168.100.201
192.168.100.202
2 按照步骤
[root@localhost local]# tar -zxvf kafka_2.11-0.10.1.0.tgz
[root@localhost local]# cd kafka_2.11-0.10.1.0/
[root@localhost kafka_2.11-0.10.1.0]# mkdir logs
[root@localhost kafka_2.11-0.10.1.0]# cd config/
[root@localhost config]# vi server.properties
broker.id=0
listeners=PLAINTEXT://192.168.100.200:9092
advertised.listeners=PLAINTEXT://192.168.100.200:9092
log.dirs=/usr/local/kafka_2.11-0.10.1.0/logs/
zookeeper.connect=192.168.100.200:2181,192.168.100.201:2181,192.168.100.202:2181
[root@localhost local]# scp -r /usr/local/kafka_2.11-0.10.1.0 192.168.100.201:/usr/local/
[root@localhost local]# scp -r /usr/local/kafka_2.11-0.10.1.0 192.168.100.202:/usr/local/
在其它两个节点上修改
broker.id=1
listeners=PLAINTEXT://192.168.100.201:9092
advertised.listeners=PLAINTEXT://192.168.100.201:9092
broker.id=2
listeners=PLAINTEXT://192.168.100.202:9092
advertised.listeners=PLAINTEXT://192.168.100.202:9092
启动(每一个节点)
[root@localhost kafka_2.11-0.10.1.0]# bin/kafka-server-start.sh -daemon /usr/local/kafka_2.11-0.10.1.0/config/server.properties &
[root@localhost kafka_2.11-0.10.1.0]# jps
进程名为Kafka
3 验证
创建一个主题wangyl,备份3,分区2
[root@localhost kafka_2.11-0.10.1.0]# bin/kafka-topics.sh --create --topic wangyl --replication-factor 3 --partitions 2 --zookeeper 192.168.100.200:2181
查看主题
[root@localhost kafka_2.11-0.10.1.0]# bin/kafka-topics.sh --list --zookeeper 192.168.100.200:2181
生产消费模式验证
生产端
[root@localhost kafka_2.11-0.10.1.0]# bin/kafka-console-producer.sh --broker-list 192.168.100.200:9092 --sync --topic wangyl
消费端
[root@localhost kafka_2.11-0.10.1.0]# bin/kafka-console-consumer.sh --zookeeper 192.168.100.200:2181 --topic wangyl --from-beginning
列出该主题的详细信息
[root@localhost kafka_2.11-0.10.1.0]# bin/kafka-topics.sh --describe --zookeeper 192.168.100.200:2181 --topic wangyl
相关文章推荐
- zookeeper+kafka集群安装之二
- 一台机器上安装zookeeper+kafka集群
- zookeeper+kafka集群安装之中的一个
- zookeeper+kafka集群安装部署
- kafka+zookeeper集群安装与配置(CENTOS7环境)及开发中遇到的问题解决
- Spark集群安装之——Zookeeper+Kafka 安装教程
- zookeeper+kafka集群安装之二
- Zookeeper3.4.6与Kafka0.8.1.1集群安装和配置详细步骤
- zookeeper+kafka集群安装之一
- KafKa基于Zookeeper集群安装
- [参考]zookeeper集群安装 kafka 集群安装
- kafka安装应用,zookeeper集群集成测试应用
- flink集群一键安装脚本 -- kafka消息中间件依赖zookeeper集群安装脚本
- 生产环境实战spark (11)分布式集群 5台设备 Zookeeper集群、Kafka集群安装部署
- zookeeper、kafka的安装与配置以及集群
- 基于独立Zookeeper集群的Hbase 安装配置实验
- zookeeper+kafka集群安装之二
- kafka集群安装(zookeeper未使用kafka自带的)
- zookeeper+kafka集群安装之一
- HBase 分布式安装搭建/独立Zookeeper集群