@@ -138,6 +138,9 @@ func ConnectClickhouse(cHouseConfig *config.CHouseConfig) error {
Debugf: func(format string, v ...interface{}) {
fmt.Printf(format, v)
},
+ Compression: &clickhouse.Compression{
+ Method: clickhouse.CompressionLZ4,
+ },
})
if err != nil {
return err
