Тип канала Kafka в ArcGIS Velocity подписывается на внешне доступный брокер Kafka и получает сообщения от него. Kafka - это платформа распределенной потоковой передачи с открытым исходным кодом, которую вы можете использовать для следующих действий:
- Публикация и подписка на поток сообщений по темам.
- Надежное хранение потоков сообщений.
- Обработка потоков сообщений.
Примеры
Ниже приведены примеры использования канала:
- Аналитик данных хочет получать данные датчиков через брокера Kafka.
- Транспортный отдел настраивает канал Kafka для получения местоположений транспортных средств и информации об атрибутах.
Примечания по использованию
При работе с каналом учитывайте следующее:
- Этот тип канала поддерживает связность с Confluent Kafka.
- Не используйте одну группу потребителей для нескольких тем. Создать группу потребителей для каждой темы.
- Если есть несколько потребителей (канал Velocity Kafka - потребитель) использующих одну группу потребителей для приема данных темы, каждый потребитель (или канал) получает только часть данных, в зависимости от количества разделов в теме.
- Если количество потребителей темы, использующих одну группу потребителей, превышает число разделов темы, некоторые потребители не получат никаких данных.
- Не используйте группу потребителей, ссылающуюся на канал Velocity Kafka вне Velocity.
- После задания свойств подключения канала настройте входные данные, чтобы задать схему и ключевые свойства.
Параметры
Ниже приведены параметры канала:
| Параметр | Описание | Тип данных |
|---|---|---|
| Брокер | Список брокеров Kafka через запятую, указанный как server:port, например: machine1.domain.com:9092,machine2.domain.com:9092. | Строка |
| Тема | Тема Kafka, из которой Velocity получает сообщения. | Строка |
| ID группы потребителей (необязательно) | Группа потребителей Kafka Velocity присоединяется в качестве участника. | Строка |
| Аутентификация | Задает тип аутентификации, используемый при доступе к конечной точке HTTP. Опции аутентификации: Нет, SASL/PLAIN, SASL/SCRAM-SHA-256 и SASL/SCRAM-SHA-512. | Строка |
| Использовать SSL | Указывает, используется ли SSL (SASL_SSL) при подключении к брокеру Kafka. Примечание:Это должно соответствовать конфигурации, которая есть у брокера для заданного порта. Если false, Velocity подключается через PLAINTEXT. | Boolean |
| Имя пользователя | Имя пользователя для доступа к брокеру Kafka. Этот параметр применяется только при Аутентификации SASL/PLAIN, SASL/SCRAM-SHA-256 или SASL/SCRAM-SHA-512. | Строка |
| Пароль | Пароль для доступа к брокеру Kafka. Этот параметр применяется только при Аутентификации SASL/PLAIN, SASL/SCRAM-SHA-256 или SASL/SCRAM-SHA-512. | Строка |
Рекомендации и ограничение
При использовании канала учитывайте следующее:
Брокер Kafka должен быть доступен извне через интернет.