Skip to content

Conversation

@bizob2828
Copy link
Member

Description

Most tracking metrics were easy as we already instrumented. For eachBatch i wrapped it and only log tracking metric. I will add PR to angler to start tracking these metrics.

How to Test

npm run versioned:internal kafkajs

Related Issues

Closes #2247

…tation/kafkajs/<method>` to track when consumer and producer methods are being used
@bizob2828 bizob2828 force-pushed the supportability-metrics branch from 5d25f29 to 64af0bd Compare June 5, 2024 21:07
Copy link
Contributor

@jsumners-nr jsumners-nr left a 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.

Comment on lines +21 to +22
instrumentConsumer({ shim, kafkajs, recordMethodMetric })
instrumentProducer({ shim, kafkajs, recordMethodMetric })
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I don't know why I enjoy seeing object params pay off, but I do 😄

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

Archived in project

Development

Successfully merging this pull request may close these issues.

[kafkajs] Add supportability metric when consumer.run.eachMessage, consumer.run.eachBatch producer.send, and producer.sendBatch are being used

2 participants