diff --git a/message.go b/message.go index 28e5072..58cb114 100644 --- a/message.go +++ b/message.go @@ -31,7 +31,11 @@ type Message struct { // IsFailed Is only used on transactional retry disabled IsFailed bool + // ErrDescription specifies the IsFailed message's error + + // If available, kafka-konsumer writes this description into the failed message's + // headers as `x-error-message` key when producing retry topic ErrDescription string }