kq/queue.go
line 205
func (q *kafkaQueue) Stop() {
q.consumer.Close()
logx.Close()
}
logx.Close() will clear the global logs writer, before that my program turn the writer to file neutralize.
// Close closes the logging.
func Close() error {
if w := writer.Swap(nil); w != nil {
return w.(io.Closer).Close()
}
return nil
}