当从pipelinedb连接到kafka时，如何提供SASL/普通凭据？

Question

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

Answer 1

我们可以这样做：

将此patch应用于pipeline_kafka (相关的issue已关闭，但补丁从未合并)。

然后将此配置添加到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'

也许有一个更好的答案，但这个方法奏效了。