Skip to content

fix(consumer): metricize Kafka transport failures#8193

Open
onewland wants to merge 2 commits into
masterfrom
fix/kafka-transport-failure-metric
Open

fix(consumer): metricize Kafka transport failures#8193
onewland wants to merge 2 commits into
masterfrom
fix/kafka-transport-failure-metric

Conversation

@onewland

Copy link
Copy Markdown
Contributor

Summary

  • intercept Arroyo global BrokerTransportFailure events before Sentry sends them
  • increment rust_consumer.kafka_error with error=broker_transport_failure instead
  • drop the duplicate Sentry structured log while preserving local JSON output
  • preserve all other Kafka errors and add focused classifier coverage

This addresses SNUBA-AA1, a recoverable librdkafka broker connection failure that produced 744 events over the inspected 24-hour period.

Tests

  • cargo test logging::tests
  • cargo clippy --all-targets -- -D warnings
  • cargo fmt --check
  • commit hooks

@onewland
onewland requested a review from a team as a code owner July 16, 2026 23:01
Comment thread rust_snuba/src/logging.rs
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.

1 participant