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