在clickhouse的kafka表中配置ca_cert，client_cert，client_key，tls_enabled

Question

我想将 CH 连接到 TLS kafka 集群。

我的制作人使用以下内容来推送事件：

    'kafka://broker0:9092,broker1:9092,broker2:9092?
     ca_cert=redacted&
     client_cert=redacted&
     client_key=some-long-string&
tls_enabled=true&topic_prefix=some-prefix_' 

如何从消费者端配置以下内容（ch kafka 表）： ca_cert 客户端证书 客户端密钥 tls_启用

文档仅涵盖基本设置，即纯文本

Answer 1

以下所有设置都可以添加到 ClickHouse 中的 Kafka 配置中： https://github.com/confluenceinc/librdkafka/blob/master/CONFIGURATION.md - 但您必须将点 (.) 替换为下划线属性名称中的 (_)。

例如，您可以创建一个新的

kafka.xml

文件并将其放置在您的

config.d

目录中：

<clickhouse>
   <kafka>
       <security_protocol>SSL</security_protocol>
       <ssl_ca_location>/opt/kafka/my.crt</ssl_ca_location>
       <ssl_certificate_location>/etc/my.pem</ssl_certificate_location>
       <ssl_key_location>my.key</ssl_key_location>
       <ssl_key_password>my_password</ssl_key_password>

   </kafka>
</clickhouse>