zoukankan      html  css  js  c++  java
  • kafka的安装和使用

    一、下载kafka

    kafka下载地址

    二、解压启动

    tar -zxvf kafka_2.11-2.1.1.tgz -C 解压目录

    三、

    kafka依赖于zookeeper,现在的高版本自带zookeeper

     启动zookeeper:

    ./bin/zookeeper-server-start.sh ./config/zookeeper.properties

    启动kafka:

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

    四、简单使用

    在安装目录下:

    ./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

     

    查看创建的topic:

    bin/kafka-topics.sh --list --zookeeper localhost:2181

    生产者产生消息

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

    然后输入相关的消息:

    接下来消费者消费信息:

    ./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

    然后可以看到消费到刚才输入的消息

    然后再输一些:

    可以看到消费者这边已经自动出来了

    五、关闭

    可以在安装目录的bin目录下面查找以.sh结尾的文件。

  • 相关阅读:
    动手动脑
    选课1.0
    四则运算
    JAVA异常处理机制资料整理
    JAVA学习日报(快乐作业) 10.27
    JAVA学习日报(快乐作业) 10.20
    JAVA学习日报 9/30
    JAVA学习日报 9/28
    JAVA学习日报 9/27
    JAVA学习日报 9/26
  • 原文地址:https://www.cnblogs.com/chenmz1995/p/10413145.html
Copyright © 2011-2022 走看看