-
-
Notifications
You must be signed in to change notification settings - Fork 201
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
kotel: optionally only use messaging.kafka.connects.count for connection metrics #691
Conversation
@twmb I updated the PR to use |
@twmb as you've seen me moved away from relying on this monitoring plugin for the use case that spawn this contribution but I'm happy to follow along with it. I still think that it aligns better to expectations in the |
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.
Looks good to me, I wanted to wait until I finally had time for 1.17 but really that wasn't necessary -- my bad. Anyway, 1.17 is now released, and now I'll release this one too, thank you!
Ah, sorry, mind dropping the go.mod and go.sum changes? I bumped them to latest before 1.17. |
Pinging! @endorama I can clone your repo and edit your commit a bit, I'll give it another week or so but if you drop the go.mod and go.sum changes earlier, we can merge and release yours :) |
small change to align on using attribute.Set for metrics attributes.
94ed169
to
17f85d6
Compare
@twmb sorry for the delay! I removed the commit bumping otel ( Thanks for the review! |
This PR follows the discussion in #670.
I added a new struct field,
mergeConnectsMeter bool
that is manipulated byWithMergedConnectsMeter()
, to control whether to use one or 2 metrics to track connection successes/errors.By default is set to
false
to retain current behaviour.When set to
true
it disables the creation ofmessaging.kafka.connect_errors.count
metric and follows a different path inMeter.OnBrokerConnect
. There is some repetition as I wanted to avoid additional allocations when manipulating otel attributes (unfortunately Attribute Sets don't offer a way to add/remove elements from the set).I added tests for the previous and new behaviour.
Let me know what you think, happy to adjust based on your feedback and thank you for your review!