sql - 从 pipelinedb 连接到 kafka 时如何提供 SASL/PLAIN 凭据？

Question

我们想通过 PipelineDB 从 Kafka 摄取数据。我们的 Kafka 设置需要 SASL/PLAIN 身份验证。如何使用pipelinedb/ pipeline_kafkaPostgreSQL 扩展配置 SASL 用户和密码？

Answer 1

我们能够这样做：

将此补丁应用于 pipeline_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'

可能有更好的答案，但这有效。