zoukankan      html  css  js  c++  java
  • Kafka创建&查看topic,生产&消费指定topic消息

    启动zookeeper和Kafka之后,进入kafka目录(安装/启动kafka参考前面一章:https://www.cnblogs.com/cici20166/p/9425613.html)

    1.创建Topic

      1)运行命令: ./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1

      2181 是zookeeper 端口

      图示为创建成功:

      

    2.查看Topic

      1)运行命令查看所有的topic: ./bin/kafka-topics.sh --list --zookeeper localhost:2181

      结果如下图,表示共有test和test1两个topic:

      

    3.用Kafka的console-producer在topic test1 生产消息

      新建终端窗口,到/Applications/kafka目录,运行命令:./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test1

      然后输入想要产生的消息内容(如 hello world),回车:

        

    4.用Kafka的console-consumer 消费topic test1的消息

      新建终端窗口,到/Applications/kafka目录,

      运行命令:./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test1 --from-beginning

      (9092是kafka单机启动的端口;--bootstrap-server   新旧kafka版本不一样,这个是新版本的命令)

      

      ps. 1)若producer 和 consumer 两个窗口同时打开,在producer输入信息,consumer会立即消费信息并打印在终端

         2)新开一个终端,去消费同一个topic,刚刚已经消费过的消息还会被新终端继续消费。也就是说,消息被消费过后不会立即被删除。           

        

  • 相关阅读:
    JavaScrip 数组/字典/循环
    初识javaScript
    css内容补充之其它
    position
    css的存在形式
    CSS选择器
    Html的Head内标签
    Linux设置FQDN
    saltstack 全面介绍
    jQuery文档处理
  • 原文地址:https://www.cnblogs.com/cici20166/p/9426417.html
Copyright © 2011-2022 走看看