zoukankan      html  css  js  c++  java
  • kafka zookeeper学习(2) 测试kafka与zookeeper环境

      上节搭建了zookeeper与kafka环境,这一节要测试环境是否能正常工作。

    1,紧接着上节的内容,zookeeper与kafka都启动好了,新开一个命令窗口,定为到

      D:softkafka_2.11-0.9.0.0inwindows

    2,创建topic

    输入命令  .kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test 来创建topic 名为test。topic可以理解为一个逻辑队列,逻辑队列里存放消息的是若干个(可配置)partitions。

    3,创建一个生产者和一个消费者来测试消息

      打开两个命令窗口, 定为到D:softkafka_2.11-0.9.0.0inwindows,一个用于producer,另一个作为consumer

      a)创建producer

      kafka-console-producer.bat --broker-list localhost:9092 --topic test

      b)创建consumer

      kafka-console-consumer.bat --zookeeper localhost:2181 --topic test

      得到两个命令窗口如下:

      如果成功了 在producer窗口输入内容可以在consumer窗口打印出来,如下:

      

  • 相关阅读:
    XidianOJ 1099 A simple problem
    XidianOJ 1097 焊板子的xry111
    XidianOJ 1172 Hiking
    XidianOJ 1176 ship
    bzoj1912(树的直径)
    黑暗城堡(最短路径树)
    poj1639(k限制最小生成树)
    0-1分数规划
    tyvj1391(Kruskal)
    [Usaco2007 Nov]Cow Relays(矩阵乘法+floyd)
  • 原文地址:https://www.cnblogs.com/Forrest-Janny/p/6953073.html
Copyright © 2011-2022 走看看