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

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

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容