search

childe / gohangout

使用 golang 模仿的 Logstash。用于消费 Kafka 数据，处理后写入 ES、Clickhouse 等。
MIT License
1.01k stars 234 forks source link

kafka output ，compress.type配置压缩为lz4，发送不成功 #214

Open bj1116 opened 1 year ago

bj1116 commented 1 year ago

kafka output ，compress.type配置压缩为lz4，发送不成功

childe commented 1 year ago

kafka output ，compress.type配置压缩为lz4，发送不成功

我晚点看一下。另外，有没有具体的报错？

bj1116 commented 1 year ago

10304 simple_producer.go:262] decode produce response error: The server experienced an unexpected error when processing the request