Как удалить тему, используя Кафка Кафка остальные Прокси?
Как удалить тему Кафки с помощью Kafka REST Proxy ? Я попробовал следующую команду, но она возвращает сообщение об ошибке:
curl -X DELETE XXX.XX.XXX.XX:9092/topics/test_topic
Если это невозможно, то как обновить удалить сообщения и обновить схему темы?
2 ответа:
Согласно документации API Reference, вы не можете удалять темы через REST Proxy, и я согласен с ними, потому что такая деструктивная операция не должна быть доступна через интерфейс, который подвергается воздействию извне.
Операция удаления темы может быть выполнена на сервере, где брокер работает с помощью утилиты командной строки. Смотрите Как удалить тему в apache kafka
Вы можете обновить схему сообщения при его публикации с помощью конечной точки REST POST / topics/(string: topic_name). Если схема для новых сообщений не является обратно совместимой со старыми сообщениями в том же разделе, вам придется настроить реестр схемы, чтобы разрешить публикацию несовместимых сообщений, в противном случае вы получите сообщение об ошибке.
Смотрите "пример запроса Avro" здесь: http://docs.confluent.io/3.1.1/kafka-rest/docs/api.html#post--topics-(string-topic_name)
Смотрите, как настроить реестр схем для прямой, обратной или нулевой совместимости смотрите документацию здесь: http://docs.confluent.io/3.1.1/schema-registry/docs/api.html#compatibility