Команда TOPIC_CLEAR

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

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

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

Синтаксис 

java -jar <dtm_tools_file_name>.jar \
--connect <prostore_host>:<prostore_port> \
topic_clear \
--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.

Примеры

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

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

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

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

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

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