Запуск системы регистрации конфлюэнтов в окнах

Question

У меня есть среда для окон и мой собственный набор кафки и зоопарка. Чтобы использовать пользовательские объекты, я начал использовать Avro. Но мне нужно было запустить реестр. Скачивал платформу Confluent и побежал это:

$ ./bin/schema-registry-start ./etc/schema-registry/schema-registry.properties 
/c/Confluent/confluent-3.0.0-2.11/confluent-3.0.0/bin/schema-registry-run-class: line 103: C:\Program: No such file or directory 

Тогда я вижу это на странице установки:

«Сливной настоящее время не поддерживает Windows, пользователь Windows, можно загрузить и использовать почтовые и смолистые архивы, но будут иметь. для запуска файлов jar напрямую, а не для использования сценариев оболочки в каталоге bin /. "

Мне было интересно, как мне начать процесс создания конфлюэнтной схемы в среде Windows?

Посмотрел содержимое скриптов и его трудно расшифровать.

Благодаря

Answer 1

На данный момент Сливной платформа не поставляется с любыми сценариями для Windows. Однако вы можете написать свой собственный, если вам будет удобно работать с Java-приложениями. Сценарий schema-registry-server-start (и сценарий schema-registry-run-class) зависит от того, как он работает: например, дескриптор -daemon, задайте параметры памяти Java, настройте конфигурацию журнала по умолчанию и т. Д., Но в конечном итоге ключевым моментом является то, что они выполняют Java с io.confluent.kafka.schemaregistry.rest.SchemaRegistryMain в качестве основного метода. Вы также можете найти kafka-run-class.bat из Кафки в качестве полезной базы: https://github.com/apache/kafka/blob/trunk/bin/windows/kafka-run-class.bat

Answer 2

Проблема, скорее всего, наличие пробелов в среде JAVA_HOME настройки для среды Windows, (о чем свидетельствует сообщение об ошибке «C: \ Program», а чем «C: \ Program Files ...».

Вы можете определить синтаксис EXACT финального вызова Java для запуска schema_registry, добавив замену последнего «exec» в скрипте сценария схемы-сценария с помощью слово «эхо». Вы увидите довольно запутанную команду

/Library/Java/JavaVirtualMachines/jdk1.8.0_91.jdk/Contents/Home/bin/java -Xmx512M -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:/opt/confluent/bin/../etc/schema-registry/log4j.properties -cp :/opt/confluent/bin/../package-schema-registry/target/kafka-schema-registry-package-*-development/share/java/schema-registry/*:/opt/confluent/bin/../share/java/confluent-common/*:/opt/confluent/bin/../share/java/rest-utils/*:/opt/confluent/bin/../share/java/schema-registry/* io.confluent.kafka.schemaregistry.rest.SchemaRegistryMain 

Это сотрудничество mmand сводится к «java [core-java-opts] [java-определяет] -cp [classpath] io.confluent.kafka.schemaregistry.rest.SchemaRegistryMain

Если вы замените ссылки«/opt/confluent »на фактическое местоположение вашей Confluent install, я подозреваю, что вам повезет намного лучше.

ПРИМЕЧАНИЕ: Я предпочитаю, чтобы установить Java на окна в месте клиента (например, «C: \ java8», так как многие стандартные сценарии будут иметь проблемы с C:. \ Program Files развертывания расположение

Answer 3

Я имел Успешная работа с запущенными инструментами из cmd.exe с использованием cygwin.

C:\>c:\cygwin64\bin\bash -l /cygdrive/c/confluent/4.0.0/bin/kafka-avro-console-consumer --bootstrap-server <my_server_name>:9092 --topic <my_topic> --property schema.registry.url=http://<my_schema_registry_url>:8081 >> tmp.txt