zoukankan      html  css  js  c++  java
  • kafka之topic

    kafka

    一.列出topic
    ./kafka-topics.sh --list --zookeeper ZooKeeper的任意一个节点或者全部的IP:Port/kafka


    二.查看某一topic详细信息
    ./kafka-topics.sh --zookeeper localhost:2181 --topic topic名称 --describe

    三.创建topic
    ./kafka-topics.sh --create --topic topic名称 --partitions 分区数 --replication-factor 备份数 --zookeeper ZooKeeper的任意一个节点或者全部的IP:Port/kafka


    四.修改topic
    ./kafka-topics.sh --alter --topic topic名称 --config 配置项=配置值
    如:
    ./kafka-topics.sh -zookeeper localhost:2181 --topic 主题名称 --alter --config message.timestamp.type=LogAppendTime 

    #设置时间戳类型为broker接收到这条消息的时间

    可视化工具:Kafdrop

  • 相关阅读:
    每日日报
    每日日报
    每日日报
    每日日报
    每日日报
    每日日报
    每日日报
    每日日报
    每日日报
    COM对象
  • 原文地址:https://www.cnblogs.com/itfenqing/p/14616128.html
Copyright © 2011-2022 走看看