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结尾的文件。

  • 相关阅读:
    目录 —— C语言数据结构与算法分析
    目录 —— STM32裸机
    目录 —— FreeRTOS
    常用存储器介绍
    DMA(Data Memory Access)直接存储器访问
    命令
    文件数据流向
    野指针产生的原因
    内存四区
    SVG 是什么?
  • 原文地址:https://www.cnblogs.com/chenmz1995/p/10413145.html
Copyright © 2011-2022 走看看