search

childe / gohangout

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

uncompress records bytes error #203

Closed jinmuyano closed 1 year ago

jinmuyano commented 1 year ago

E0114 17:45:39.447080 3997 fetch_response.go:525] uncompress records bytes error: uncompress gzip records error: unexpected EOF E0114 17:45:39.447118 3997 simple_consumer.go:448] consumer nginxlog[0] error:uncompress records bytes error: uncompress gzip records error: unexpected EOF

childe commented 1 year ago

看这个报错的意思是说解压 Gzip 消息的时候，数据异常中断。不确定是代码有问题，还是数据本身有问题。可以以下两步看看。

  1. 用 Kafka 官方的消费者消费一下看看有没有问题
  2. 运行 gohangout 的时候，加参数 -v 10 看一下详细的日志
Cerberuxx commented 1 year ago

@jinmuyano 请问这个问题解决了吗？我也碰到同样的报错了加上-v 10也没有看到可用的报错信息

childe commented 1 year ago

@jinmuyano 请问这个问题解决了吗？我也碰到同样的报错了加上-v 10也没有看到可用的报错信息

没有。 日志默认都打印到文件，不输出到屏幕。

childe commented 1 year ago

fix in https://github.com/childe/healer/commit/2caca95d323d725033a6b2d7620c774c5bcbf200