Apache Kafka – Инструменты

Kafka Tool упакован в «org.apache.kafka.tools. *. Инструменты подразделяются на системные инструменты и инструменты репликации.

Системные инструменты

Системные инструменты могут быть запущены из командной строки, используя скрипт класса run. Синтаксис выглядит следующим образом –

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

Некоторые из системных инструментов упомянуты ниже –

  • Kafka Migration Tool – этот инструмент используется для миграции брокера с одной версии на другую.
  • Mirror Maker – этот инструмент используется для обеспечения зеркалирования одного кластера Kafka другому.
  • Consumer Offset Checker – этот инструмент отображает Consumer Group, Topic, Partition, Off-set, logSize, Owner для указанного набора тем и Consumer Group.

Инструмент репликации

Репликация Kafka – это инструмент проектирования высокого уровня. Целью добавления инструмента репликации является повышение надежности и доступности. Некоторые из инструментов репликации упомянуты ниже –

  • Create Topic Tool – создает тему с количеством разделов по умолчанию, коэффициентом репликации и использует схему по умолчанию Kafka для выполнения реплики.
  • Add Partition Tool  – этот инструмент выводит информацию для заданного списка тем. Если в командной строке нет тем, инструмент запрашивает у Zookeeper все темы и выводит информацию о них. Поля, которые отображает инструмент, – это название темы, раздел, лидер, реплики, isr.
  • Add Partition Tool – Создание темы, необходимо указать количество разделов для темы. Позже для темы может потребоваться больше разделов, когда объем темы увеличится. Этот инструмент помогает добавить больше разделов для определенной темы, а также позволяет вручную назначать реплики добавленным разделам.

Leave a Reply

Your email address will not be published. Required fields are marked *