Как запустить прокси-сервер kafka на окнах

Question

Как запустить прокси-сервер kafka на окнах.

Я скачал сливающийся-2.0.1-2.11.7.tar.gz

в папке Windows я не могу видеть Кафка-Rest старт.

Answer 1

В настоящее время Windows не поддерживается. Тем не менее, он должен работать нормально, если вы адаптируете скрипт. Даже работающий java io.confluent.kafkarest.KafkaRestMain с соответствующим классом должен работать.

Answer 2

Возможно, этот ответ поможет любому, кто не знаком с Кафкой и наткнется на эту ситуацию, как и я :).

Я искал ответ на тот же вопрос неделю назад, наткнулся на официальном предложении, чтобы запустить банку файлы (в этом пути сливающийся-ххх \ доля \ Java \ Кафка-отдых) в окнах и было Не удалось это сделать.

Всегда сталкивался с этой ошибкой no main attribute found с указанием или без указания пути к классам и io.confluent.kafkarest.KafkaRestMain.

Я даже попробовал запустить сценарии оболочки, упакованные для дистрибутива Linux, используя [babun]: http://babun.github.io/, но это привело к ошибке, например, Error: Could not find or load main class io.confluent.kafkarest.KafkaRestMain.

В конечном счете изображение докеры, построенное с помощью zookeeper, kafka, schema-registry, kafka-rest, работало как шарм. Вот официальная страница с информацией о названии изображения, далее ссылка на это документ: https://hub.docker.com/r/confluentinc/cp-kafka-rest/

После вытягивать этот образ, новая виртуальная машина получает создана с более четырех изображений внутри него (по одному для каждой службы, как зоопарк, Кафка , системный реестр и Kafka-rest). Запуск изображений выполняется отдельным контейнером Docker.

Это руководство, чтобы вы начали быстро: http://docs.confluent.io/current/cp-docker-images/docs/quickstart.html

И, наконец, если вы хотели бы выставить прокси-сервер Кафка REST работает в качестве контейнера Докер к внешней сети (например, окна машины, которая является частью отдельного сети, чем эти контейнеры) просто укажите IP-адрес Docker host (найдите его, нажав docker-machine ip <hostname>) в KAFKA_REST_LISTENERS и выставьте порт с опцией -p.

Как это:

docker run -d \ 
    --net=host \ 
    --name=kafka-rest \ 
    -p 8082:8082 \ 
    -e KAFKA_REST_ZOOKEEPER_CONNECT=localhost:32181 \ 
    -e KAFKA_REST_LISTENERS=http://192.168.99.100:8082 \ 
    -e KAFKA_REST_SCHEMA_REGISTRY_URL=http://localhost:8081 \ 
    -e KAFKA_REST_HOST_NAME=localhost \ 
    confluentinc/cp-kafka-rest:3.2.1 

Если все в порядке, вы будете иметь возможность получить доступ к REST прокси на этот адрес http://<Docker_host_IP>:8082 из машины окна.

Answer 3

Вот пример команды, они на самом деле, выполняющаяся в конце сценария Баша:

java -Xmx256M -server -XX:+UseG1GC -XX:MaxGCPauseMillis=20 -XX:InitiatingHeapOccupancyPercent=35 -XX:+DisableExplicitGC -Djava.awt.headless=true -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false -Dlog4j.configuration=file:C:/Dev/kafka/confluent-4.0.0/etc/kafka-rest/log4j.properties -cp .;C:/Dev/kafka/confluent-4.0.0/target/kafka-rest-*-development/share/java/kafka-rest/*;C:/Dev/kafka/confluent-4.0.0/share/java/confluent-common/*;C:/Dev/kafka/confluent-4.0.0/share/java/rest-utils/*;C:/Dev/kafka/confluent-4.0.0/share/java/kafka-rest/* io.confluent.kafkarest.KafkaRestMain C:/Dev/kafka/confluent-4.0.0/etc/kafka-rest/kafka-rest.properties 

Убедитесь, что вы измените путь к вашему, если вы хотите попробовать его.