(code int16, msg *string)
| 37 | } |
| 38 | |
| 39 | func newKafkaErrorWithDynamicMessage(code int16, msg *string) error { |
| 40 | kafkaErr := kerr.TypedErrorForCode(code) |
| 41 | if kafkaErr == nil { |
| 42 | return nil |
| 43 | } |
| 44 | return &KerrWithDynamicMessageError{Static: kafkaErr, DynamicServerMessage: msg} |
| 45 | } |
no outgoing calls
searching dependent graphs…