Выходной коннектор Записать текст в Kafka Topic может использоваться для записи данных событий, адаптированных и отформатированных как текст с разделителями, в Apache Kafka Topic. Для получения информации о работе с Apache Kafka см. раздел Введение в Apache Kafka.
Примечания по использованию
При работе с выходным коннектором Записать текст в Kafka Topic имейте в виду следующее:
- Для точки, этот процессор будет создавать эквивалентную точку.
- Имея линию с двумя вершинами, этот процессор создаст такую же линию.
- Имея простой выпуклый полигон (многоугольник) или оболочку, этот процессор создаст эквивалентную ему геометрию.
- Используйте этот выходной коннектор для записи данных, адаптированных и отформатированных как текст с разделителями, в Kafka Topic. Этот входной коннектор является производителем для Kafka.
- Этот выходной коннектор связывает исходящий адаптер Text с исходящим транспортом Kafka.
- Перед записью в Kafka для форматирования записей событий в виде текста с разделителями необходимы разделитель сообщений и разделитель атрибутов. Разделитель сообщений указывает символ, определяющий конец записи данных; по умолчанию используется \n (новая строка). Разделитель атрибутов задает символ, используемый для отделения одного атрибута от другого в отдельной строке текста; по умолчанию используется , (запятая). Любой стандартный ASCII-символ, заданный как символ или значение Юникод, может использоваться в качестве разделителя сообщений или атрибутов.
- Входящий транспорт Kafka поддерживает протоколы безопасности TLS 1.2 и SASL для аутентификации с помощью кластера или брокера Kafka.
Параметры
Ниже приведены параметры выходного коннектора Записать текст в Kafka Topic:
| Параметр | Описание |
|---|---|
Имя | Описательное имя входного коннектора, используемое для ссылки в GeoEvent Manager. |
Заменить пользовательскими свойствами Kafka | Укажите, следует ли переопределять свойства клиента GeoEvent Server Kafka по умолчанию. По умолчанию Нет.
|
Серверы Kafka Bootstrap (Условия) | Список пар hostname:port, используемых для установки исходного подключения к кластеру Kafka. Пары Hostname:port должны быть разделены запятыми, например, broker0.example.com:9092,broker1.example.com:9092,broker2.example.com:9092. |
Зарегистрированная папка для файла свойств Kafka (Условия) | Папка, зарегистрированная на GeoEvent Server, содержащая файл Kafka .properties. Файл Kafka .properties определяет пользовательские свойства Kafka, когда для параметра Заменить пользовательскими свойствами Kafka установлено Да. Убедитесь, что папка, зарегистрированная на GeoEvent Server, является полным путем к местоположению файла Kafka.properties. |
Имя файла свойств Kafka (Условия) | Имя файла Kafka .properties, содержащего пользовательские свойства Kafka для конфигурации клиента. Имя файла должно быть указано без расширения .properties.
|
Название темы | Имя темы Kafka, в которую публикуются данные.
Примечание:Исходящий транспорт Kafka не поддерживает публикацию данных в нескольких темах. |
Включить Доставку только один раз | Указывает, следует ли при написании на тему соблюдать семантику exactly-once. Для получения дополнительной информации см. Семантика Exactly-once Semantics. По умолчанию – Да.
Примечание:Убедитесь, что кластер Kafka поддерживает семантику exactly-once, прежде чем продолжить работу с параметром Включить Доставку только один раз. Включение семантики exactly-once влияет на уровень производительности. Дополнительную информацию см. в разделе Конфигурации производителя, в отношении подтверждений. |
Разделитель событий | Один буквенный символ, который указывает на конец записи данных событий. Значения Unicode могут применяться для указания разделителя символов. Этот символ не должен заключаться в кавычки. Перенос строки (\n) - это наиболее типичный разделитель конца записи. |
Разделитель полей | Один буквенный символ, используемый для отделения одного значения атрибута от другого в сообщении. Значения Unicode могут применяться для указания разделителя символов. Этот символ не должен заключаться в кавычки. Обычно разделителем атрибутов является запятая. |
Выходной формат даты | Задает формат значений даты/времени, записанных в файл. Доступный выходной формат даты – Формат ISO 8601 или Пользовательский формат. По умолчанию – Формат ISO 8601.
|
Пользовательский формат даты | Пользовательский формат для значений даты/времени, записанных в файл. Пользовательский формат даты должен быть построен с использованием соглашения о классе Java SimpleDateFormat. Более подробно см. SimpleDateFormat. |
Язык форматирования чисел | Идентификатор локали (ID), используемый для чувствительного к локали поведения при форматировании чисел из значений данных. По умолчанию используется локаль компьютера, на котором установлен GeoEvent Server. Дополнительные сведения см. в разделе Поддерживаемые локали Java. |
Необходима аутентификация | Указывает, требуется ли аутентификация для подключения к кластеру Kafka или брокеру Kafka. По умолчанию Нет.
|
Аутентификация с использованием (Условия) | Указывает протокол безопасности, используемый для защиты кластера Kafka. Доступные протоколы безопасности включают TLS 1.2 и SASL.
Примечание:Используя Kerberos, убедитесь, что у учетной записи операционной системы, от имени которой запущен ArcGIS GeoEvent Server, есть права на чтение файла keytab в настройке и конфигурации Kerberos. Параметр показывается, когда для свойства Требуется аутентификация задано Да. |
Зарегистрированная папка для файла учетных данных (Условия) | Папка, зарегистрированная в GeoEvent Server, которая содержит файл PKI кластера Kafka (сертификат x509). Убедитесь, что папка, зарегистрированная на GeoEvent Server, является полным путем к местоположению сертификата кластера Kafka. |
Файл конфигурации учетных данных (Условия) | Имя файла PKI кластера Kafka (сертификат x509). Сертификат и связанный с ним ключ должны храниться в формате PKCS#12, который представлен файлом с расширением .p12 или .pfx. Укажите имя файла в дополнении к расширению.
Примечание:Для этого параметра поддерживаются только имя файла сертификата и расширение. Относительные пути к сертификату не должны указываться в этом параметре. Зарегистрируйте полный путь к файлу сертификата с помощью параметра Зарегистрированная папка для файла учетных данных. Параметр показывается, когда для свойства Требуется аутентификация задано Да. Это применимо только к протоколу TLS 1.2. |
Пароль Keystore (Условия) | Пароль для файлв PKI кластера Kafka (сертификат x509). Он также известен как личный ключ сертификата. |
Тип аутентификации SASL (Условия) | Определяет тип механизма аутентификации SASL, поддерживаемого кластером Kafka. Доступные типы аутентификации SASL включают SASL GSSAPI (Kerberos) и SASL PLAIN.
|
Участник Kerberos (Условия) | Участник Kerberos для определенного пользователя, например, GeoEventKafkaClient1@example.com. |
Использовать Key Tab (Условия) | Указывает, следует ли использовать keytab в настройках Kerberos. По умолчанию – Да.
|
Хранить ключ (Условия) | Указывает, следует ли хранить ключ в настройках Kerberos. По умолчанию – Да.
|
Username (Условия) | Указывает имя пользователя, используемое для аутентификации в кластере Kafka. Он также известен как строка подключения с определенными провайдерами облачных ресурсов. Обратитесь к документации выбранного провайдера облачных услуг для получения правильного синтаксиса. |
Пароль (Условия) | Указывает пароль, используемый для аутентификации в кластере Kafka. Обратитесь к документации выбранного провайдера облачных услуг для получения правильного синтаксиса. |
Советы и ограничения
Выходной коннектор Записать текст в Kafka Topic является производителем для Kafka. К этому выходному коннектору применяются те же рекомендации, что и к любому другому внешнему производителю для Kafka.