# [FAQ] drainer 日志报 got error from broker 是否会影响数据复制

## Key Words

binlog, drainer, kafka, got error from broker

## Description

drainer 报以下异常日志，message 中明显显示有错误，但 log level 是 INFO。

```log
[2022/10/25 00:36:00.085 +08:00] [INFO] [syncer.go:260] ["write save point"] [ts=436896929787674655] [version=1343712]
[2022/10/25 00:36:03.658 +08:00] [INFO] [syncer.go:260] ["write save point"] [ts=436896930744500227] [version=1343712]
[2022/10/25 00:36:04.037 +08:00] [INFO] [client.go:772] ["[sarama] client/metadata fetching metadata for [tidbbinloghs] from broker sjtb2:9092\n"]
[2022/10/25 00:36:04.043 +08:00] [INFO] [client.go:818] ["[sarama] client/metadata got error from broker 2 while fetching metadata: write tcp 10.102.6.252:38698->10.102.3.71:9092: write: broken pipe\n"]
[2022/10/25 00:36:04.043 +08:00] [INFO] [broker.go:253] ["[sarama] Closed connection to broker sjtb2:9092\n"]
[2022/10/25 00:36:04.043 +08:00] [INFO] [client.go:556] ["[sarama] client/brokers deregistered broker #2 at sjtb2:9092"]
[2022/10/25 00:36:04.043 +08:00] [INFO] [client.go:772] ["[sarama] client/metadata fetching metadata for [tidbbinloghs] from broker sjtb1:9092\n"]
[2022/10/25 00:36:04.043 +08:00] [INFO] [client.go:818] ["[sarama] client/metadata got error from broker 1 while fetching metadata: write tcp 10.102.6.252:37096->10.102.3.70:9092: write: broken pipe\n"]
[2022/10/25 00:36:04.043 +08:00] [INFO] [broker.go:253] ["[sarama] Closed connection to broker sjtb1:9092\n"]
[2022/10/25 00:36:04.043 +08:00] [INFO] [client.go:556] ["[sarama] client/brokers deregistered broker #1 at sjtb1:9092"]
[2022/10/25 00:36:04.043 +08:00] [INFO] [client.go:772] ["[sarama] client/metadata fetching metadata for [tidbbinloghs] from broker sjtb5:9092\n"]
[2022/10/25 00:36:04.044 +08:00] [INFO] [client.go:534] ["[sarama] client/brokers registered new broker #2 at sjtb2:9092"]
[2022/10/25 00:36:04.044 +08:00] [INFO] [client.go:534] ["[sarama] client/brokers registered new broker #1 at sjtb1:9092"]
[2022/10/25 00:36:06.816 +08:00] [INFO] [syncer.go:260] ["write save point"] [ts=436896931544039427] [version=1343712]
[2022/10/25 00:36:10.443 +08:00] [INFO] [syncer.go:260] ["write save point"] [ts=436896932343578628] [version=1343712]
```

## Content

这样的日志是 drainer 从 Kafka 断开重连时打印的日志，所以这个日志不会影响数据复制，也不会造成数据丢失或重复，因为 drainer 是基于 checkpoint 保存复制进度的，如果数据没有复制到下游，checkpoint 是不会更新的。
日志中在断开后，马上进行了重连尝试，并且成功，是不影响数据复制的。

## Affected Versions

All