zoukankan      html  css  js  c++  java
  • kafka使用自带zookeeper 单机版安装、配置、启动、生产消费消息测试

    1.安装kakfka
    1.从官网下载Kafka安装包,解压安装,或直接使用命令下载。

    wget https://archive.apache.org/dist/kafka/0.11.0.0/kafka_2.11-0.11.0.0.tgz
    2.解压
    tar -xzvf kafka_2.11-0.11.0.0.tgz

    2.修改配置文件
    vim config/server.properties
    broker.id=1
    delete.topic.enable=true

    log.dirs=/usr/local/kafka/logs


    listeners=PLAINTEXT://localhost:9092

    修改zookeeper.properties
    dataDir路径

    修改zookeeper连接地址


    3.启动并测试
    1.一定要先启动zookeeper服务
    bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
    -daemon 是阻塞进程
    2.启动单机kafka服务
    bin/kafka-server-start.sh config/server.properties
    3.创建topic进行测试
    bin/kafka-topic.sh --create --zookeeper localhost:2128 --replication–factor 1 --partitions 1 --topic test
    4.查看topic列表
    bin/kafka-topic.sh --list --zookeeper localhost:9092 --topic test
    输出test
    5.生产者消息测试
    bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
    6.消费者消息测试
    bin/kafka-console-consumer.sh --zookeeper localhost:2128 --toptic test --from-beginning

  • 相关阅读:
    基于JFinal中搭建wopi协议支撑办法
    mysql 增加列
    国王分金币
    口算题卡升级版本
    elasticsearch牛人的日志列表
    牛B的大数据库
    golang --rune
    golang ---rune与byte
    golang学习笔记--接口
    golang学习笔记--函数和方法
  • 原文地址:https://www.cnblogs.com/weiwei-python/p/14780064.html
Copyright © 2011-2022 走看看