Skip to content

feat(producer): add metrics for callback execution latency#544

Merged
bmckerry merged 4 commits into
mainfrom
ben/callback-latency
Jun 18, 2026
Merged

feat(producer): add metrics for callback execution latency#544
bmckerry merged 4 commits into
mainfrom
ben/callback-latency

Conversation

@bmckerry

Copy link
Copy Markdown
Member

This PR adds a metric for the latency between producing a message and executing that message's callback.

@bmckerry bmckerry requested review from a team as code owners June 18, 2026 18:57
Comment thread arroyo/backends/kafka/consumer.py Outdated
Comment thread arroyo/backends/kafka/consumer.py Outdated
@bmckerry bmckerry force-pushed the ben/callback-latency branch from 3a84a1e to 5845b8d Compare June 18, 2026 19:00
Comment thread tests/backends/test_confluent_producer.py

@cursor cursor Bot left a comment

Copy link
Copy Markdown

Choose a reason for hiding this comment

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

Cursor Bugbot has reviewed your changes and found 1 potential issue.

Fix All in Cursor

❌ Bugbot Autofix is OFF. To automatically fix reported issues with cloud agents, enable autofix in the Cursor dashboard.

Reviewed by Cursor Bugbot for commit 2de8e7b. Configure here.

Comment thread tests/backends/test_kafka_producer.py Outdated
Comment thread arroyo/backends/kafka/consumer.py
@bmckerry bmckerry merged commit fe38552 into main Jun 18, 2026
20 checks passed
@bmckerry bmckerry deleted the ben/callback-latency branch June 18, 2026 19:29
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants