zilla examples
1.0.0
Этот репозиторий содержит коллекцию примеров папок, которые можно использовать индивидуально для демонстрации ключевых функций Zilla. Если это ваш первый шаг на пути к Zilla, мы рекомендуем вам попробовать наш Быстрый старт.
Вам понадобится среда с установленными Docker или Helm и Kubernetes. Ознакомьтесь с нашими коллекциями Postman, чтобы узнать больше о способах взаимодействия с примером.
Сценарий startup.sh предназначен для помощи в настройке и удалении необходимых компонентов для каждого из примеров. Его использование — самый простой способ взаимодействия с каждым примером.
Установите и запустите любой из примеров, используя скрипт startup.sh :
./startup.sh -m example.name Вы можете указать свой собственный хост и порт Kafka или рабочий каталог, в который вы хотите загрузить примеры. Существующие каталоги примеров not будут перезаписаны.
./startup.sh -m -k kafka:9092 -d /tmp example.nameАльтернативно вы можете запустить этот скрипт таким же образом, не клонируя репозиторий.
wget -qO- https://raw.githubusercontent.com/aklivity/zilla-examples/main/startup.sh | sh -s -- -m example.name./startup.sh --help Usage: startup.sh [-hm][-k KAFKA_BOOTSTRAP_SERVER][-d WORKDIR][-v ZILLA_VERSION][-e EX_VERSION][--no-kafka-init][--redpanda] example.name
Operand:
example.name The name of the example to use [default: quickstart][string]
Options:
-d | --workdir Sets the directory used to download and run the example [string]
-e | --ex-version Sets the examples version to download [default: latest][string]
-h | --use-helm Use the helm install, if available, instead of compose [boolean]
-k | --kafka-server Sets the Kafka Boostrap Server to use [string]
-m | --use-main Download the head of the main branch [boolean]
-v | --zilla-version Sets the zilla version to use [default: latest][string]
--auto-teardown Executes the teardown script immediately after setup [boolean]
--no-kafka-init The script wont try to bootstrap the kafka broker [boolean]
--redpanda Makes the included kafka broker and scripts use Redpanda [boolean]
--help Print help [boolean]
| Имя | Описание |
|---|---|
| асинкапи.mqtt.proxy | Пересылает проверенные сообщения публикации MQTT и прокси-серверы подписывается на брокера MQTT. |
| asyncapi.mqtt.kafka.proxy | Пересылает сообщения публикации MQTT в Kafka, транслируя их всем подписанным клиентам MQTT. |
| asyncapi.http.kafka.proxy | Сопоставляет HTTP-запросы и ответы по отдельным темам Kafka. |
| асинкапи.ссе.прокси | Сообщения, проверенные прокси, доставляемые сервером SSE |
| asyncapi.sse.kafka.proxy | Потоковые сообщения, опубликованные в теме Kafka через SSE. |
| tcp.echo | Отображает байты, отправленные на TCP-сервер. |
| tcp.reflect | Отображает байты, отправленные на TCP-сервер, и передает их всем TCP-клиентам. |
| tls.echo | Отображает зашифрованные байты, отправленные на сервер TLS. |
| tls.reflect | Отображает зашифрованные байты, отправленные на сервер TLS, и передает их всем клиентам TLS. |
| http.файловая система | Обслуживает файлы из каталога локальной файловой системы. |
| http.filesystem.config.server | Обслуживает файлы из каталога локальной файловой системы, получая конфигурацию с http-сервера. |
| http.echo | Отображает запрос, отправленный на HTTP-сервер от HTTP-клиента. |
| http.echo.jwt | Отображает запрос, отправленный на HTTP-сервер от HTTP-клиента, авторизованного JWT. |
| http.прокси | Прокси-запрос отправлен на HTTP-сервер от HTTP-клиента |
| http.proxy.schema.inline | Прокси-запрос отправлен на HTTP-сервер от HTTP-клиента с применением схемы. |
| http.kafka.sync | Сопоставляет HTTP-запросы и ответы по отдельным темам Kafka. |
| http.kafka.async | Сопоставляет HTTP-запросы и ответы по отдельным темам Kafka в асинхронном режиме. |
| http.kafka.cache | Обслуживает кэшированные ответы из темы Kafka, обнаруживает при обновлении |
| http.kafka.oneway | Отправляет сообщения в тему Kafka, «выстрелил и забыл». |
| http.kafka.crud | Предоставляет REST API с операциями CRUD, где уплотненная по журналу тема Kafka действует как таблица. |
| http.kafka.sasl.scram | Отправляет сообщения в Kafka с поддержкой SASL/SCRAM. |
| http.kafka.karapace | Проверка сообщений при создании и загрузке в тему Kafka. |
| http.redpanda.sasl.scram | Отправляет сообщения в кластер Redpanda с поддержкой SASL/SCRAM. |
| kubernetes.prometheus.autoscale | Демонстрация функции горизонтального автомасштабирования подов в Kubernetes, основанной на специальной метрике с помощью Prometheus |
| grpc.echo | Отображает сообщения, отправленные на сервер gRPC от клиента gRPC. |
| grpc.kafka.echo | Отображает сообщения, отправленные в тему Kafka через gRPC из клиента gRPC. |
| grpc.kafka.fanout | Потоковые сообщения, опубликованные в теме Kafka, с применением объединения на основе сжатия журналов. |
| grpc.kafka.proxy | Сопоставляет запросы и ответы gRPC по отдельным темам Kafka. |
| grpc.proxy | Прокси-запросы и ответы gRPC, отправляемые на сервер gRPC от клиента gRPC. |
| amqp.reflect | Отображает сообщения, опубликованные на сервере AMQP, и транслирует их всем принимающим клиентам AMQP. |
| mqtt.kafka.broker | Пересылает сообщения публикации MQTT в Kafka, транслируя их всем подписанным клиентам MQTT. |
| mqtt.kafka.broker.jwt | Пересылает сообщения публикации MQTT в Kafka, транслируя их всем подписанным клиентам MQTT, авторизованным JWT. |
| быстрый старт | Запускает конечные точки для всех протоколов (HTTP, SSE, gRPC, MQTT). |
| sse.kafka.fanout | Потоковые сообщения, опубликованные в теме Kafka, с применением объединения на основе сжатия журналов. |
| sse.proxy.jwt | Прокси-сообщения, доставляемые сервером SSE, обеспечивая соблюдение ограничений безопасности потоковой передачи. |
| ws.echo | Эхо сообщений, отправленных на сервер WebSocket. |
| ws.reflect | Отображает сообщения, отправленные на сервер WebSocket, транслируя их всем клиентам WebSocket. |
Прочтите документы. Попробуйте примеры. Присоединяйтесь к сообществу Slack.
