Linux成长库

在zookeeper基础上搭建kafka(单节点)

2017-08-04  本文已影响9人  泡菜爱上WaSabi

1、下载kafka安装包

http://kafka.apache.org/

kafka_2.10-0.9.0.0.tgz(这里以kafka_2.10-0.9.0.0.tgz为例,单机配置,分布是后面会说到)

2、解压

tar -xvf kafka_2.10-0.9.0.0.tgz

3、添加kafka环境变量

vim /etc/profile

#kafka环境变量

export KAFKA_HOME=/root/kafka

export PATH=$PATH:$KAFKA_HOME/bin

4、启动单机模式

修改配置文件

cd /root/kafka/config

vim server.properties

broker.id=0        //为依次增长的:0、1、2、3、4,集群中唯一id

log.dirs=/root/kafka/logs    //日志地址

zookeeper.connect=master:2181,slave1:2181,slave2:2181 //zookeeperServers列表,各节点以逗号分开

(这里使用单节点,zookeeper.connect=localhost:2181)

启动kafka,但先要确保zookeeper启动

nohup bin/kafka-server-start.sh config/server.properties &

nohup &:实现在后台启动

# netstat -tunlp|egrep "(2181|9092)"

tcp        0      0 :::9092                    :::*                        LISTEN      57688/java

tcp        0      0 :::2181                    :::*                        LISTEN      57246/java

5、简单测试

启动producer

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

启动consumer

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

上一篇下一篇

猜你喜欢

热点阅读