多语言展示
当前在线:582今日阅读:86今日分享:14

zookerper + kafka安装方法

Kafka是分布式发布-订阅消息系统,ZooKeeper是一个分布式的、分层级的文件系统,能促进客户端间的松耦合。两者可以很好的配合起来使用。
方法/步骤
1

两者都需要java环境,本次安装的版本为apache-zookeeper-3.5.5-bin.tar.gz、kafka_2.11-2.3.0.tgz

2

[root@localhost ~]# tar zxf apache-zookeeper-3.5.5-bin.tar.gz [root@localhost ~]# mv apache-zookeeper-3.5.5-bin /usr/local/zookerper

3

进入配置目录conf下复制配置文件cp zoo_sample.cfg zoo.cfg

4

进入bin目录下面启动zookerper./zkServer.sh startps -ef|grep zookerper

5

解压并重命名[root@localhost ~]# tar zxf kafka_2.11-2.3.0.tgz [root@localhost ~]# mv kafka_2.11-2.3.0 /usr/local/kafka

6

kafka的主要配置文件server.properties[root@localhost kafka]# cat config/server.properties |grep -v ^$|grep -v ^#  broker.id=0advertised.listeners=PLAINTEXT://ip:9092num.network.threads=3num.io.threads=8socket.send.buffer.bytes=102400socket.receive.buffer.bytes=102400socket.request.max.bytes=1log.dirs=/tmp/kafka-logsnum.partitions=1num.recovery.threads.per.data.dir=1offsets.topic.replication.factor=1transaction.state.log.replication.factor=1transaction.state.log.min.isr=1log.retention.hours=168log.segment.bytes=1log.retention.check.interval.ms=300000zookeeper.connect=localhost:2181zookeeper.connection.timeout.ms=6000group.initial.rebalance.delay.ms=0auto.create.topics.enable=truecontrolled.shutdown.enable=trueauto.leader.rebalance.enable=truedelete.topic.enble=true [root@localhost kafka]#

8

查看server.log 日志看kafka是否启动成功

推荐信息