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窗口打印出来,如下:

      

  • 相关阅读:
    哈夫曼编码拓展题
    TrieTree
    并查集
    hash一致性
    布隆过滤器
    如何计算完全二叉树的结点数?
    如何翻转单链表和双向链表
    如何判断是搜索二叉树与完全二叉树
    文本分类之特征描述vsm和bow
    文本分类概述
  • 原文地址:https://www.cnblogs.com/Forrest-Janny/p/6953073.html
Copyright © 2011-2022 走看看