美文网首页Linux成长库
在zookeeper基础上搭建kafka(单节点)

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

作者: 泡菜爱上WaSabi | 来源:发表于2017-08-04 16:57 被阅读9次

    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

    相关文章

      网友评论

        本文标题:在zookeeper基础上搭建kafka(单节点)

        本文链接:https://www.haomeiwen.com/subject/nkcblxtx.html