kafka1.0.0集群安装部署

原创
2018/04/19 16:01
阅读数 57

我们使用官网比较新的2.11_1.0.0版本安装。

1.官网上下载安装包 http://kafka.apache.org/downloads

输入图片说明

kafka_2.11-1.0.0.tgz

接下来解压jar包: tar -zxvf kafka_2.11-1.0.0.tgz

2.修改zookeeper.properties配置文件

initLimit=10
syncLimit=5 server.1=192.168.1.101:2888:3888
server.2=192.168.1.102:2888:3888
server.3=192.168.1.102:2888:3888

3.修改server.properties配置文件

broker.id=0

listeners=PLAINTEXT://:9092

advertised.listeners=PLAINTEXT://外网IP地址:9092

advertised.host.name=192.168.1.101

zookeeper.connect=192.168.1.101:2181,192.168.1.102:2181,192.168.1.103:2181

default.replication.factor=2

num.partitions=5

log.dirs=/mnt/data/kafka-logs

4.测试集群

生产者窗口: ./kafka-console-producer.sh --broker-list 192.168.1.101:9092,192.168.1.102:9092,192.168.1.103:9092 --topic test

消费者窗口:

./kafka-console-consumer.sh --zookeeper 192.168.1.101:2181,192.168.1.102:2181,192.168.1.103:2181 --topic test --from-beginning

展开阅读全文
打赏
0
0 收藏
分享
加载中
更多评论
打赏
0 评论
0 收藏
0
分享
返回顶部
顶部