从pipelinedb连接到kafka时，如何提供SASL / PLAIN凭证？

Question

我们想通过PipelineDB从Kafka中提取数据。我们的Kafka设置需要SASL / PLAIN身份验证。如何使用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'

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