diff --git a/flow/connectors/clickhouse/clickhouse.go b/flow/connectors/clickhouse/clickhouse.go index b61e07c319..0fc25d5407 100644 --- a/flow/connectors/clickhouse/clickhouse.go +++ b/flow/connectors/clickhouse/clickhouse.go @@ -2,6 +2,7 @@ package connclickhouse import ( "context" + "crypto/tls" "database/sql" "fmt" @@ -85,6 +86,9 @@ func connect(ctx context.Context, config *protos.ClickhouseConfig) (*sql.DB, err Username: config.User, Password: config.Password, }, + TLS: &tls.Config{ + InsecureSkipVerify: true, + }, }) if err := conn.PingContext(ctx); err != nil {