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

  • 相关阅读:
    Idea中SpringBoot热部署搭建
    Redis 集群搭建
    centos7 vsftp搭建
    Centos 7 安装jdk
    Centos7 安装nginx
    Xshell 连接Linux
    python 的mysql 操作
    NIO/BIO
    java基础-3
    java基础-2
  • 原文地址:https://www.cnblogs.com/weiwei-python/p/14780064.html
Copyright © 2011-2022 走看看