Kafka工具

Kafka工具包装在org.apache.kafka.tools.*下。 工具分为系统工具和复制工具。

系统工具

系统工具可以使用run class脚本从命令行运行。 语法如下 –

bin/kafka-run-class.sh package.class -- options

下面提到了一些系统工具 –

  • Kafka迁移工具 – 此工具用于将代理从一个版本迁移到另一个版本。
  • Mirror Maker – 此工具用于将一个Kafka集群镜像到另一个。
  • 消费者偏移量检查器 – 此工具显示指定的一组主题和使用者组的消费者组,主题,分区,偏移量,日志大小,所有者。

复制工具

Kafka复制是一个高层次的设计工具。 添加复制工具的目的是提供更强的耐用性和更高的可用性。 下面提到了一些复制工具 –

  • 创建主题工具 – 这会创建一个包含默认分区数量,复制因子的主题,并使用Kafka的默认方案执行副本分配。

  • 列表主题工具 – 此工具列出给定主题列表的信息。 如果在命令行中没有提供主题,该工具将查询Zookeeper以获取所有主题并列出它们的信息。 该工具显示的字段是主题名称,分区,领导,副本,isr。

  • 添加分区工具 – 创建主题时,必须指定主题的分区数量。 稍后,当话题量增加时,话题可能需要更多的分区。 此工具有助于为特定主题添加更多分区,还可以手动添加分区的副本分配。

        原文作者:Kafka教程
        原文地址: https://www.yiibai.com/kafka/apache_kafka_tools.html
        本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系博主进行删除。
    点赞