(code int16, message string)
| 665 | } |
| 666 | |
| 667 | func makeError(code int16, message string) error { |
| 668 | if code == 0 { |
| 669 | return nil |
| 670 | } |
| 671 | if message == "" { |
| 672 | return Error(code) |
| 673 | } |
| 674 | return fmt.Errorf("%w: %s", Error(code), message) |
| 675 | } |
| 676 | |
| 677 | // WriteError is returned by kafka.(*Writer).WriteMessages when the writer is |
| 678 | // not configured to write messages asynchronously. WriteError values contain |