conduktor.io ↗

Kafka PushTelemetry Changelog — Protocol Version History

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.

VersionKafkaChanges
PushTelemetryRequest
v03.7
+ ClientInstanceId uuid
+ SubscriptionId int32
+ Terminating bool
+ CompressionType int8
+ Metrics bytes
~ Flexible encoding enabled FLEXIBLE
PushTelemetryResponse
v03.7
+ ThrottleTimeMs int32
+ ErrorCode int16
~ Flexible encoding enabled FLEXIBLE