Тип канала Kafka в ArcGIS Velocity подписывается на внешне доступный брокер Kafka и получает сообщения от него. Kafka - это платформа распределенной потоковой передачи с открытым исходным кодом, которую вы можете использовать для следующих действий:
- Публикация и подписка на поток сообщений по темам.
- Надежное хранение потоков сообщений.
- Обработка потоков сообщений.
Для получения дополнительной информации о Kafka см. документацию Apache Kafka.
Примеры
Ниже приведены примеры использования канала Kafka:
- Аналитик данных хочет получать данные датчиков через брокера Kafka.
- Транспортный отдел настраивает канал Kafka для получения местоположений транспортных средств и информации об атрибутах.
Примечания по использованию
При работе с каналом Kafka учитывайте следующее:
- Этот тип канала поддерживает связность с Confluent Kafka.
- Не используйте одну группу потребителей для нескольких тем. Создать группу потребителей для каждой темы.
- Если есть несколько потребителей (канал Velocity Kafka - потребитель) использующих одну группу потребителей для приема данных темы, каждый потребитель (или канал) получает только часть данных, в зависимости от количества разделов в теме.
- Если количество потребителей темы, использующих одну группу потребителей, превышает число разделов темы, некоторые потребители не получат никаких данных.
- Не используйте группу потребителей, ссылающуюся на канал Velocity Kafka вне Velocity.
- После настройки параметров подключения канала изучите раздел Настройка входных данных, чтобы научиться задавать схему и ключевые параметры.
Параметры
Ниже приведены параметры канала Kafka:
| Параметр | Описание | Тип данных |
|---|---|---|
Брокер | Список брокеров 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 должен быть доступен извне через интернет.