|
@@ -208,7 +208,10 @@ func (p *Producer) Close() error {
|
|
|
for event := range p.errors {
|
|
for event := range p.errors {
|
|
|
errors = append(errors, event)
|
|
errors = append(errors, event)
|
|
|
}
|
|
}
|
|
|
- return errors
|
|
|
|
|
|
|
+ if len(errors) > 0 {
|
|
|
|
|
+ return errors
|
|
|
|
|
+ }
|
|
|
|
|
+ return nil
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
///////////////////////////////////////////
|
|
///////////////////////////////////////////
|