zoukankan      html  css  js  c++  java
  • windows下使用kafka的常用命令

    参考文档:

    https://blog.csdn.net/evankaka/article/details/52421314

    http://orchome.com/6

    1 启动zookeeper

    cmd进入zookeeper的bin目录,输入zkServer.cmd

    2 启动kafka

    cmd进入kafka的安装目录

    .inwindowskafka-server-start.bat .configserver.properties

    创建主题,

    1.进入Kafka安装目录D:kafka_2.11-1.1.0
    2.按下Shift+右键,选择“打开命令窗口”选项,打开命令行。
    3.现在输入

    只有一个分区和一个备份:

    .inwindowskafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

    创建好之后,可以通过运行以下命令,查看已创建的topic信息:(查看的是所有的主题)
    .inwindowskafka-topics.bat --list --zookeeper localhost:2181
    查看指定主题的详细信息:
    .inwindowskafka-topics.bat --describe --zookeeper localhost:2181 --topic test
     

    通过describe与under-replicated-partitions命令组合使用,可以查看处于“under-replicated(复制)”状态的分区。处于该状态的主题可能正在进行同步操作

    .inwindowskafka-topics.bat --describe --zookeeper localhost:2181 --under-replicated-partitions

    删除主题:
    1 在server.properties下面增加:
    delete.topic.enable=true
    .inwindowskafka-topics.bat --delete --zookeeper localhost:2181 --topic test

    注意不要关了这个窗口!

    (2)创建生产者

    1.进入Kafka安装目录D:kafka_2.11-1.1.0
    2.按下Shift+右键,选择“打开命令窗口”选项,打开命令行。
    3.现在输入

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

     

    创建消费者

    1.进入Kafka安装目录D:kafka_2.11-1.1.0
    2.按下Shift+右键,选择“打开命令窗口”选项,打开命令行。
    3.现在输入

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

    测试:

     
    消费者可以同过whitelist订阅多个主题:

    .inwindowskafka-console-consumer.bat --zookeeper localhost:2181 --whitelist "test1|test2"

     
  • 相关阅读:
    我开发过程中用到的工具
    我最近写的DataGrid合并/删除相同列通用函数,跟大家分享
    开源项目- Archive Explorer
    SQLite准备出3.0了!
    软件缺陷管理指南 3
    介绍一些.net好站点
    几个著名java开源缓存系统的介绍
    SQL中的Where,Group By,Order By和Having的用法/区别
    Unix/Linux中Cron的用法
    java中判断字符串是否为纯数字
  • 原文地址:https://www.cnblogs.com/james-roger/p/9006668.html
Copyright © 2011-2022 走看看