Клиент Apache Beam + Kafka с учетными данными Kerberos

Попытка реализовать поток данных (задание Apache Beam) для подключения к Kafka Broker с учетными данными Kerberos.

Насколько я понимаю -

  1. используйте KafkaIO.Read.withConsumerFactoryFn для предоставления фабричной функции, которая будет вызываться для создания потребителя Kafka. это займет учетные данные SSL

  2. Создайте файл конфигурации для учетных данных Kerberos - конфигурация клиента Kafka с помощью keytab для производителей:

    KafkaClient {com.sun.security.auth.module.Krb5LoginModule требуется useKeyTab=true keyTab="/etc/security/keytabs/storm.service.keytab" storeKey=true useTicketCache=false serviceName="kafka" Principal="storm@EXAMPLE.COM"; };

Может ли кто-нибудь посоветовать, как это можно собрать в рабочее решение.

благодаря

Источник

0 ответов

Другие вопросы по тегам