New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Get access to message payload #211
Conversation
// Nack signals the producing side an erroring condition or inconsistency. | ||
func (m *message) Nack() error { | ||
messageConfirmationCountInc("NACK") | ||
trace.SpanError(m.span) | ||
return nil | ||
} | ||
|
||
// Source returns the kafka topic where the message arrived. | ||
func (m *message) Source() string { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I just swapped Source() and Nack() so that we have the same order in all the implem & the interface
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
nice! I always had this urge to make this change. Happy that the use-case came up :)
Codecov Report
@@ Coverage Diff @@
## master #211 +/- ##
==========================================
- Coverage 84.48% 84.38% -0.11%
==========================================
Files 52 52
Lines 3074 3099 +25
==========================================
+ Hits 2597 2615 +18
- Misses 398 402 +4
- Partials 79 82 +3
Continue to review full report at Codecov.
|
🚢 |
Closes #210.