THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
PushTelemetryRequest { ClientInstanceId string // client.id + “-” + UUID4 unique for this client instance. // Must be set to Null on the first request, and to the // returned ClientInstanceId from the first response // for all subsequent requests to any broker. Terminating bool // Client is terminating. ContentType string // “application/x-protobuf;oltpversiontype=0.7”oltp07” or “application/x-protobuf+zstd;oltpversion=0.7”oltp07” Metrics binary // Format specified by ContentType, possibly compressed. } PushTelemetryResponse { ThrottleTime int32 // Standard and metric-specific throttling ErrorCode int16 // Error code ClientInstanceId string // Will be set to a generated unique id if the // request ClientInstanceId was Null, else // this field will be set to Null. AcceptedContentTypes Array[string] // Accepted metric formats. // Only returned if Request.ContentType is null // or empty, or ErrorCode is set to // UnsupportedFormat(?). // Also includes the supported compression types. NextPushMs int32 // Delay until next PushTelemetry RequestedMetrics Array[string] // Requested Metrics prefix string match. // Empty array: No metrics subscribed. // Array[0] empty string: All metrics subscribed. // Array[..]: prefix string match } |
The ContentType in the client's PushTelemetryRequest must include a type parameter describing the data format, in this case oltp07 for OpenTelemetry protocol v0.7. This is needed since OLTP is not yet at v1 and may thus have backwards-incompatible changes.
Broker metrics receiver
TBD / Xavier Léauté
...
The PushTelemtryRequest.ContentType must then be set to application/x-protobuf+zstd;oltpversiontype=0.7oltp07 (or any of the other Kafka-supported compression codecs: gzip, snappy, lz4, zstd).
...