Building Observable Streaming Systems with OpenTelemetry
summary
Shows how to get end to end traces across Apache Pulsar by wiring OpenTelemetry into a Java Spring Boot producer and a Go consumer and proves it works. Uses the OpenTelemetry Java agent to auto instrument HTTP and Redis, adds a Pulsar producer interceptor that creates a span and injects its context into the message, and uses the Go TextMapPropagator to extract the context and continue the span. Elastic APM shows producer and consumer child spans and a custom counter metric named custom.metric.brand.com that rises to 3 after three requests.
AI-written summary · about
chapters (9)
- 0:00Introduction and speaker intro
- 2:16Demo application overview
- 5:45Current observability state
- 11:45Fixing async transaction visibility
- 18:01Producer-side instrumentation
- 20:28Consumer-side instrumentation
- 23:55End-to-end transaction tracing
- 26:23Adding custom metrics
- 29:39Summary and Q&A
related talks
41mTracing event-based systems with OpenTelemetry
26mThe Art of Event Driven Observability with OpenTelemetry
51mPractical introduction to OpenTelemetry tracing
43mTracing Kafka with OpenTelemetry
28mPractical Introduction to OpenTelemetry Tracing
34mOpenTelemetry for Dummies: Instrumenting Go Apps
49mAdding OpenTelemetry to Production Apps Lessons Learned
40mPractical introduction to OpenTelemetry tracing