conduktor.io ↗

Kafka PushTelemetry Response Wire Format v0 — Binary Protocol Layout

What is PushTelemetry?

Delivers OpenTelemetry-encoded metrics to the broker on the interval agreed during GetTelemetrySubscriptions (KIP-714). This enables broker-side aggregation of client metrics without external agents: latency histograms, record error rates, and connection stats flow through here.

Related Errors

TELEMETRY_TOO_LARGE · UNKNOWN_SUBSCRIPTION_ID

Wire Diagram

Response Header · flexible
message_size int32 · 4B
correlation_id int32 · 4B
tagged var
PushTelemetryResponse v0
ThrottleTimeMs int32 · 4B
ErrorCode int16 · 2B
tagged var

Schema & Example

Schema
{
  "ThrottleTimeMs": int32,
  "ErrorCode": int16
}
Example
{
  "ThrottleTimeMs": 0,
  "ErrorCode": 0
}