Apache Kafka - Инструменты
Kafka Tool упакован в папку org.apache.kafka.tools. *. Инструменты подразделяются на системные инструменты и инструменты репликации.
Системные инструменты
Системные инструменты можно запускать из командной строки с помощью сценария запуска класса. Синтаксис следующий -
bin/kafka-run-class.sh package.class - - optionsНекоторые из системных инструментов упомянуты ниже -
Kafka Migration Tool - Этот инструмент используется для переноса брокера с одной версии на другую.
Mirror Maker - Этот инструмент используется для обеспечения зеркального отображения одного кластера Kafka в другой.
Consumer Offset Checker - Этот инструмент отображает группу потребителей, тему, разделы, смещение, размер журнала, владельца для указанного набора тем и группу потребителей.
Инструмент репликации
Репликация Kafka - это инструмент проектирования высокого уровня. Целью добавления инструмента репликации является повышение надежности и доступности. Некоторые из инструментов репликации упомянуты ниже -
Create Topic Tool - Это создает тему с количеством разделов по умолчанию, коэффициентом репликации и использует схему Kafka по умолчанию для назначения реплик.
List Topic Tool- Этот инструмент отображает информацию по заданному списку тем. Если в командной строке не указаны темы, инструмент запрашивает Zookeeper, чтобы получить все темы и перечисляет информацию для них. Поля, отображаемые инструментом, - это имя темы, раздел, лидер, реплики, isr.
Add Partition Tool- Создание темы, необходимо указать количество разделов для темы. В дальнейшем для темы могут потребоваться дополнительные разделы, когда объем темы увеличится. Этот инструмент помогает добавить больше разделов для определенной темы, а также позволяет вручную назначать реплики добавленных разделов.