Получить сообщения
Last updated
Last updated
Eng: Receive message Kafka
Компонент предназначен для получения сообщений из очереди сервера Kafka. Используется в RPA-процессах для обработки данных, поступающих через Kafka, что позволяет интегрировать процессы и системы, работающие с потоками сообщений.
Символ *
в названии свойства указывает на обязательность заполнения. Описание общих свойств см. в разделе Свойства элемента.
Сервер
ID группы
String
Идентификатор группы.
Адрес сервера*
String
Адрес сервера Kafka (localhost:9092)
Защищенный пароль
SecureString
Защищенный пароль для подключения к серверу Kafka.
Имя топика/очереди*
String
Имя топика или очереди, из которой требуется получить сообщение.
Логин
String
Логин для подключения к серверу Kafka.
Пароль
String
Пароль для подключения к серверу Kafka.
Таймаут*
Int32
Предельное время ожидания завершения процесса (мс)
Сообщение
Ожидать сообщения
Boolean
Указывает, следует ли ожидать поступления новых сообщений от сервера.
SSL
Функция доступна с версии 1.24.8
Защищенный пароль ключа
SecureString
Защищенный пароль для доступа к ключу.
Использовать SSL
Boolean
Указывает, следует ли использовать SSL для защищенного соединения.
Механизм
String
Механизм SASL для аутентификации (например, PLAIN, SCRAM-SHA-256, SHA-512, Gssapi, OAuth Bearer).
Пароль ключа
String
Пароль для доступа к ключу, используемому для SSL.
Проверять сертификат
Boolean
Указывает, следует ли проверять достоверность сертификата при установлении соединения.
Протокол
String
Протокол безопасности, используемый для SSL (например, PLAINTEXT, SSL).
Путь к ключу
String
Путь к ключу, который используется для SSL-соединений.
Путь к сертификату
String
Путь к сертификату, который используется для SSL-соединений.
Хранилища
String
Хранилища сертификатов, используемые для SSL-соединений.
GSSAPI (Kerberos)
Использует Kerberos для аутентификации, что является стандартом в крупных корпоративных сетях. GSSAPI предоставляет безопасную и устойчивую аутентификацию, обычно используется в средах, где требуется высокая безопасность. Подробнее на официальном сайте Kerberos Documentation
Plain
Использует простой текст для передачи имени пользователя и пароля. Это самый простой и часто используемый метод аутентификации, но он менее безопасен по сравнению с другими механизмами. Используется в сценариях, где SSL уже предоставляет достаточный уровень безопасности для передачи учетных данных.
Scram Sha256
Использует механизм SCRAM с хэшированием пароля с использованием алгоритма SHA-256. SCRAM (Salted Challenge Response Authentication Mechanism) предоставляет более безопасную форму аутентификации по сравнению с Plain. Подходит для случаев, когда нужно повысить безопасность при аутентификации, сохраняя при этом простоту настройки. SCRAM Mechanisms
Scram Sha512
Также использует механизм SCRAM, но с более сильным алгоритмом хэширования SHA-512. Это еще более безопасная версия SCRAM, обеспечивающая высокий уровень защиты паролей. Идеален для сред, где безопасность является приоритетом, и требуется максимальная защита учетных данных.
OAuth Bearer
Использует токены OAuth для аутентификации. OAuth Bearer является современным механизмом аутентификации, широко применяемым для авторизации и доступа к ресурсам через RESTful API. Подходит для сценариев, где Kafka используется в облачных средах или где уже развернута система OAuth для управления доступом. Подробнее можно ознакомиться в официальной документации OAuth 2.0 Authorization Framework
Plaintext — Этот протокол передает данные в открытом виде, без шифрования. Используется для незащищенных соединений.
Ssl — Обеспечивает шифрование данных через SSL (Secure Sockets Layer). Используется для защиты данных при передаче.
Sasl Plaintext — Протокол с механизмом аутентификации SASL, но без шифрования. Данные передаются в открытом виде, однако используется аутентификация для обеспечения подлинности пользователей.
Sasl Ssl — Протокол, сочетающий шифрование данных через SSL и механизм аутентификации SASL. Обеспечивает высокий уровень защиты данных.
Пример использования элемента в процессе с типом Только код (Pure code):