Loop error when write log to kafka fail

[vuhoanghiep1993]

I create a multi writer to file and to kafka as in project https://github.com/vasupal1996/go-app.git

The implement of kafka is : https://github.com/vasupal1996/go-app/blob/master/server/logger/kafkaLogger.go

Problem is when kafka server is down, the diode.poll() loop infinite so it write log a lot

func (kw *KafkaLogWriter) Write(p []byte) (n int, err error) {
    m := kafka.Message{
        Value: p,
    }
    err = kw.WriteMessages(context.Background(), m)
    if err != nil {
        log.Printf("failed to write log message to kafka topic:")
        return 0, err
    }
    return len(p), nil
}

I also want to ask how this infinite for break ,

func (dw Writer) poll() {
    defer close(dw.done)
    for {
        d := dw.d.Next() // -----> when debug, in normal case it out of for loop here, when kafka error, it loop infinite
        if d == nil {
            return
        }
        p := *(*[]byte)(d)
        dw.w.Write(p)

        // Proper usage of a sync.Pool requires each entry to have approximately
        // the same memory cost. To obtain this property when the stored type
        // contains a variably-sized buffer, we add a hard limit on the maximum buffer
        // to place back in the pool.
        //
        // See https://golang.org/issue/23199
        const maxSize = 1 << 16 // 64KiB
        if cap(p) <= maxSize {
            bufPool.Put(p[:0])
        }
    }
}