Получить сообщения Kafka

Eng: Receive message Kafka

Компонент предназначен для получения сообщений из очереди сервера Kafka. Используется в RPA-процессах для обработки данных, поступающих через Kafka, что позволяет интегрировать процессы и системы, работающие с потоками сообщений.

Свойства

Символ * в названии свойства указывает на обязательность заполнения. Описание общих свойств см. в разделе Свойства элемента.

Механизмы аутентификации в Kafka:

1. GSSAPI (Kerberos)
   • Использует Kerberos для аутентификации, что является стандартом в крупных корпоративных сетях. GSSAPI предоставляет безопасную и устойчивую аутентификацию, обычно используется в средах, где требуется высокая безопасность. Подробнее на официальном сайте Kerberos Documentation 
2. Plain
   • Использует простой текст для передачи имени пользователя и пароля. Это самый простой и часто используемый метод аутентификации, но он менее безопасен по сравнению с другими механизмами. Используется в сценариях, где SSL уже предоставляет достаточный уровень безопасности для передачи учетных данных.
3. Scram Sha256
   • Использует механизм SCRAM с хэшированием пароля с использованием алгоритма SHA-256. SCRAM (Salted Challenge Response Authentication Mechanism) предоставляет более безопасную форму аутентификации по сравнению с Plain. Подходит для случаев, когда нужно повысить безопасность при аутентификации, сохраняя при этом простоту настройки. SCRAM Mechanisms 
4. Scram Sha512
   • Также использует механизм SCRAM, но с более сильным алгоритмом хэширования SHA-512. Это еще более безопасная версия SCRAM, обеспечивающая высокий уровень защиты паролей. Идеален для сред, где безопасность является приоритетом, и требуется максимальная защита учетных данных.
5. OAuth Bearer
   • Использует токены OAuth для аутентификации. OAuth Bearer является современным механизмом аутентификации, широко применяемым для авторизации и доступа к ресурсам через RESTful API. Подходит для сценариев, где Kafka используется в облачных средах или где уже развернута система OAuth для управления доступом. Подробнее можно ознакомиться в официальной документации OAuth 2.0 Authorization Framework 

Описание протоколов:

1. Plaintext — Этот протокол передает данные в открытом виде, без шифрования. Используется для незащищенных соединений.
2. Ssl — Обеспечивает шифрование данных через SSL (Secure Sockets Layer). Используется для защиты данных при передаче.
3. Sasl Plaintext — Протокол с механизмом аутентификации SASL, но без шифрования. Данные передаются в открытом виде, однако используется аутентификация для обеспечения подлинности пользователей.
4. Sasl Ssl — Протокол, сочетающий шифрование данных через SSL и механизм аутентификации SASL. Обеспечивает высокий уровень защиты данных.

Только код

Пример использования элемента в процессе с типом Только код (Pure code):

List<LTools.Network.MQ.KafkaMessage> ret = LTools.Network.MqApp.Kafka_Receive("localhost:9092", "login", "password", "topic", "groupId", true, 10000);

ret = LTools.Network.MqApp.Kafka_Receive("localhost:9092", "login", "password", "topic", "groupId", True, 10000)

var ret = _lib.LTools.Network.MqApp.Kafka_Receive("localhost:9092", "login", "password", "topic", "groupId", true, 10000);