Как предоставить учетные данные SASL / PLAIN при подключении из pipelinedb к kafka?

Question

Мы хотим получать данные из Кафки через PipelineDB.Наша настройка Kafka требует аутентификации SASL / PLAIN.Как настроить пользователя и пароль SASL с расширением pipelinedb / pipeline_kafka PostgreSQL?

Answer 1

Мы смогли сделать это так:

Примените это исправление к pipe_kafka (связанная проблема была закрыта, но исправление не было объединено).

Затем добавьте эту конфигурацию к postgresql.conf:

shared_preload_libraries = 'pipelinedb,pipeline_kafka'
pipeline_kafka.broker_version = '1.0.0'
pipeline_kafka.consumer_config = 'security.protocol=SASL_PLAINTEXT,sasl.mechanisms=PLAIN,sasl.username=USER,sasl.password=PASSWORD'

Возможно, есть лучший ответ, но это сработало.