7x31/sniffer-agent
1
0
Fork 0
mirror of https://github.com/zr-hebo/sniffer-agent.git synced 2025-09-18 01:37:06 +08:00
Code Issues Packages Projects Releases Wiki Activity

为kafka消息添加压缩设置

Browse Source
This commit is contained in:
hebo
2019-12-13 11:41:10 +08:00
parent c95ded78e9
commit e68e06ec81
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
exporter/kafka.go
View File

@@ -54,7 +54,7 @@ func checkParams() {
case "lz4":
compressType = sarama.CompressionLZ4
default:
panic(fmt.Sprintf("cannot support compress type: %s", compress))
panic(fmt.Sprintf("cannot support kafka compress type: %s", compress))
}
fmt.Printf("kafka message compress type: %s", compress)