В Confluent (https://confluent.cloud), похоже, нет возможности выключить кластер Kafka:
Я пытаюсь ограничить свои расходы и выключить кластер. Я изучил различные варианты на скриншоте выше, но я не нашел места, где можно выключить кластер.
В Confluent (https://confluent.cloud), похоже, нет возможности выключить кластер Kafka:
Я пытаюсь ограничить свои расходы и выключить кластер. Я изучил различные варианты на скриншоте выше, но я не нашел места, где можно выключить кластер.
Я считаю, что в панели управления Confluent такой опции нет; В качестве варианта можно использовать интерфейс командной строки Confluent ( Confluent CLI).
В предыдущих версиях использовалась следующая команда:
Я считаю, что в более новых версиях единственный вариант остановить кластер с помощью интерфейса командной строки - использовать _ 2_; Проблема в следующем:
Сливающиеся локальные команды предназначены для одноузловой среды разработки и не подходят для производственной среды.
В этом случае вы можете остановить брокера, позвонив:
confluent local services kafka stop
Или все сервисы, запущенные с платформы Confluent:
confluent local services stop
< / а>
Это может быть связано с проблемами безопасности, чтобы избежать остановки кластера развертывания из-за неправильного нажатия не той кнопки. Таким образом, опция остановки кластера развертывания предполагает ручную остановку каждого брокера (например, путем вызова kafka-server-stop.sh) без помощи графического интерфейса или командной строки. Я знаю, что этот ответ может совсем не помочь, но надеюсь, что он был каким-то образом информативным.
Изменить - из Confluent Kafka Rest Proxy. репо -
Способ привязки прокси Rest к Confluent Cloud объясняется здесь: свяжите прокси Rest с Confluent Cloud. Если вы смогли это сделать, вы можете вызвать его сценарий остановки, чтобы распространить его на экземпляры брокеров облака, даже если задокументированные клиенты для привязки - это только потребитель, производитель и администратор
Развертывание
Прокси-сервер REST включает встроенный сервер Jetty. Сценарии оболочки bin / kafka-rest-start и bin / kafka-rest-stop являются рекомендуемым методом запуска и остановки службы.
Это содержимое / bin / kafka-rest -stop скрипт:
exec $(dirname $0)/kafka-rest-stop-service '(kafkarest\.Main)|(kafkarest\.KafkaRestMain)'
Что вызывает kafka-rest-stop-service скрипт:
TARGET=`ps ax | egrep -i "$1" | grep java | grep -v grep | awk '{print $1}'`
if [ "x$TARGET" = "x" ]; then
>&2 echo "No running instance found."
exit 1
fi
kill "$TARGET"
for i in `seq 20`; do
sleep 0.25
ps ax | egrep -i "$1" | grep "$TARGET" > /dev/null
if [ $? -eq 0 ]; then
exit 0
fi
done
>&2 echo "Tried to kill $TARGET but never saw it die"
exit 1
По сути, он отправляет SIGTERM
сигнал процессу, вызывая kill "$TARGET"
Таким образом, REST API может позволить вам остановить весь кластер, вызвав обернутый сценарий остановки. К сожалению, мне не удалось найти дополнительную информацию об этой команде или синтаксисе для ее вызова.