zoukankan      html  css  js  c++  java
  • kafka常用指令

    来自homie:https://www.cnblogs.com/cuiyuanhao/
    查看消费组详情:
    ./bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group test-consumer-group
    查看topic详情:
    ./bin/kafka-topics.sh --topic mytopic --describe --bootstrap-server localhost:9092
    创建topic:
    bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic mytopic --partitions 10 --replication-factor 3
    查看topic详情:
    bin/kafka-topics.sh --zookeeper localhost:2181 --desc --topic mytopic
    修改partition数量:
    bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic mytopic --partitions 10
    删除topic:
    server.properties ==> delete.topic.enable=true
    bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic mytopic
    创建终端生产者:
    bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mytopic
    .inkafka-console-producer.bat --bootstrap-server localhost:9092 --topic my-topic
    创建终端消费者:
    bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic mytopic

  • 相关阅读:
    畅通工程续
    find the safest road
    Window Pains
    什么是DO / DTO / BO / VO /AO ?
    编程四大件
    1.Redis简介和安装
    0.Redis课程大纲
    8.docker容器虚拟化与传统虚拟机比较
    7.docker私有仓库
    6.Docker服务编排
  • 原文地址:https://www.cnblogs.com/caoxueyang/p/13937605.html
Copyright © 2011-2022 走看看