Команда TOPIC_DELETE

Содержание раздела
  1. Синтаксис
    1. Параметры
    2. Ключевые слова
      1. --connect
      2. --topic
      3. --kafkaBrokers
  2. Примеры
  3. Варианты вывода команды

Команда TOPIC_DELETE удаляет топик Kafka и обнуляет прочитанное смещение для всех консьюмер-групп, подписанных на топик.

По умолчанию команда удаляет топик того брокера сообщений, который задан в конфигурации с помощью параметра ZOOKEEPER_KAFKA_ADDRESS. Чтобы удалить топик другого брокера сообщений, укажите в команде ключевое слово kafkaBrokers с адресом нужного брокера.

Синтаксис 

java -jar <dtm_tools_file_name>.jar \
--connect <prostore_host>:<prostore_port> \
topic_delete \
--topic <topic_name> \
[--kafkaBrokers <kafka_broker_list>]

Параметры

dtm_tools_file_name

Имя jar-файла утилиты DTM Tools.

Ключевые слова

--connect

Задает строку подключения к ноде Prostore. Значение состоит из элементов:

  1. prostore_host — IP-адрес или доменное имя ноды Prostore;
  2. prostore_port — номер порта для подключения к ноде Prostore, равный значению параметра конфигурации DTM_CORE_HTTP_PORT.

--topic

Задает имя удаляемого топика Kafka.

--kafkaBrokers

Задает список адресов брокеров Kafka, содержащих топик. Значение указывается в формате host1:port1,host2:port2,..hostN:portN.

Ключевое слово нужно указывать, если список брокеров отличается от значения параметра конфигурации ZOOKEEPER_KAFKA_ADDRESS.

Топик не удаляется, если в брокере сообщений Kafka настроено автосоздание топиков.

Примеры

Удаление топика из брокера сообщений, заданного в конфигурации:

java -jar dtm-tools-1.19.jar --connect 10.92.3.86:9090 topic_delete --topic sales_700

Удаление топика из указанных брокеров сообщений:

java -jar dtm-tools-1.19.jar --connect 10.92.3.86:9090 topic_delete --topic sales_800 --kafkaBrokers 10.123.2.43:9092,10.123.2.44:9092

Варианты вывода команды

При успешном выполнении команды выдается сообщение Topic <topic_name> successfully deleted, при неуспешном — текст ошибки.