diff --git a/receiver/kafkareceiver/documentation.md b/receiver/kafkareceiver/documentation.md index debebfbe1e4d6..6859a6fb858d6 100644 --- a/receiver/kafkareceiver/documentation.md +++ b/receiver/kafkareceiver/documentation.md @@ -8,13 +8,13 @@ The following telemetry is emitted by this component. ### otelcol_kafka_broker_closed -The total number of connections closed. +The total number of connections closed. [development] Only produced when franz-go is enabled. -| Unit | Metric Type | Value Type | Monotonic | -| ---- | ----------- | ---------- | --------- | -| 1 | Sum | Int | true | +| Unit | Metric Type | Value Type | Monotonic | Stability | +| ---- | ----------- | ---------- | --------- | --------- | +| 1 | Sum | Int | true | development | #### Attributes @@ -24,13 +24,13 @@ Only produced when franz-go is enabled. ### otelcol_kafka_broker_connects -The total number of connections opened. +The total number of connections opened. [development] Only produced when franz-go is enabled. -| Unit | Metric Type | Value Type | Monotonic | -| ---- | ----------- | ---------- | --------- | -| 1 | Sum | Int | true | +| Unit | Metric Type | Value Type | Monotonic | Stability | +| ---- | ----------- | ---------- | --------- | --------- | +| 1 | Sum | Int | true | development | #### Attributes @@ -57,13 +57,13 @@ Only produced when franz-go is enabled. Deprecated in favor of kafka_broker_thro ### otelcol_kafka_broker_throttling_latency -The throttling latency in seconds imposed by the broker when receiving records. +The throttling latency in seconds imposed by the broker when receiving records. [development] Only produced when franz-go is enabled. -| Unit | Metric Type | Value Type | -| ---- | ----------- | ---------- | -| s | Histogram | Double | +| Unit | Metric Type | Value Type | Stability | +| ---- | ----------- | ---------- | --------- | +| s | Histogram | Double | development | #### Attributes @@ -73,13 +73,13 @@ Only produced when franz-go is enabled. ### otelcol_kafka_receiver_bytes -The size in bytes of received records seen by the broker. +The size in bytes of received records seen by the broker. [development] Only produced when franz-go is enabled. -| Unit | Metric Type | Value Type | Monotonic | -| ---- | ----------- | ---------- | --------- | -| By | Sum | Int | true | +| Unit | Metric Type | Value Type | Monotonic | Stability | +| ---- | ----------- | ---------- | --------- | --------- | +| By | Sum | Int | true | development | #### Attributes @@ -92,11 +92,11 @@ Only produced when franz-go is enabled. ### otelcol_kafka_receiver_bytes_uncompressed -The uncompressed size in bytes of received records seen by the client. +The uncompressed size in bytes of received records seen by the client. [development] -| Unit | Metric Type | Value Type | Monotonic | -| ---- | ----------- | ---------- | --------- | -| By | Sum | Int | true | +| Unit | Metric Type | Value Type | Monotonic | Stability | +| ---- | ----------- | ---------- | --------- | --------- | +| By | Sum | Int | true | development | #### Attributes @@ -109,11 +109,11 @@ The uncompressed size in bytes of received records seen by the client. ### otelcol_kafka_receiver_current_offset -Current message offset +Current message offset [development] -| Unit | Metric Type | Value Type | -| ---- | ----------- | ---------- | -| 1 | Gauge | Int | +| Unit | Metric Type | Value Type | Stability | +| ---- | ----------- | ---------- | --------- | +| 1 | Gauge | Int | development | #### Attributes @@ -162,11 +162,11 @@ Deprecated in favor of kafka_receiver_records. ### otelcol_kafka_receiver_offset_lag -Current offset lag +Current offset lag [development] -| Unit | Metric Type | Value Type | -| ---- | ----------- | ---------- | -| 1 | Gauge | Int | +| Unit | Metric Type | Value Type | Stability | +| ---- | ----------- | ---------- | --------- | +| 1 | Gauge | Int | development | #### Attributes @@ -177,29 +177,29 @@ Current offset lag ### otelcol_kafka_receiver_partition_close -Number of finished partitions +Number of finished partitions [development] -| Unit | Metric Type | Value Type | Monotonic | -| ---- | ----------- | ---------- | --------- | -| 1 | Sum | Int | true | +| Unit | Metric Type | Value Type | Monotonic | Stability | +| ---- | ----------- | ---------- | --------- | --------- | +| 1 | Sum | Int | true | development | ### otelcol_kafka_receiver_partition_start -Number of started partitions +Number of started partitions [development] -| Unit | Metric Type | Value Type | Monotonic | -| ---- | ----------- | ---------- | --------- | -| 1 | Sum | Int | true | +| Unit | Metric Type | Value Type | Monotonic | Stability | +| ---- | ----------- | ---------- | --------- | --------- | +| 1 | Sum | Int | true | development | ### otelcol_kafka_receiver_read_latency -The time it took in seconds to receive a batch of records. +The time it took in seconds to receive a batch of records. [development] Only produced when franz-go is enabled. -| Unit | Metric Type | Value Type | -| ---- | ----------- | ---------- | -| s | Histogram | Double | +| Unit | Metric Type | Value Type | Stability | +| ---- | ----------- | ---------- | --------- | +| s | Histogram | Double | development | #### Attributes @@ -212,11 +212,11 @@ Only produced when franz-go is enabled. ### otelcol_kafka_receiver_records -The number of received records. +The number of received records. [development] -| Unit | Metric Type | Value Type | Monotonic | -| ---- | ----------- | ---------- | --------- | -| 1 | Sum | Int | true | +| Unit | Metric Type | Value Type | Monotonic | Stability | +| ---- | ----------- | ---------- | --------- | --------- | +| 1 | Sum | Int | true | development | #### Attributes @@ -229,7 +229,7 @@ The number of received records. ### otelcol_kafka_receiver_records_delay -The time in seconds between producing and receiving a batch of records. +The time in seconds between producing and receiving a batch of records. [development] Optional, only reported when enabled via config. Note that this metric may slow down high-volume consuming. @@ -237,9 +237,9 @@ Only produced when franz-go is enabled. This metric is reported with an assumption that the exporter and the receiver clocks are synchronized. -| Unit | Metric Type | Value Type | -| ---- | ----------- | ---------- | -| s | Histogram | Double | +| Unit | Metric Type | Value Type | Stability | +| ---- | ----------- | ---------- | --------- | +| s | Histogram | Double | development | #### Attributes @@ -250,11 +250,11 @@ This metric is reported with an assumption that the exporter and the receiver cl ### otelcol_kafka_receiver_unmarshal_failed_log_records -Number of log records failed to be unmarshaled +Number of log records failed to be unmarshaled [development] -| Unit | Metric Type | Value Type | Monotonic | -| ---- | ----------- | ---------- | --------- | -| 1 | Sum | Int | true | +| Unit | Metric Type | Value Type | Monotonic | Stability | +| ---- | ----------- | ---------- | --------- | --------- | +| 1 | Sum | Int | true | development | #### Attributes @@ -265,11 +265,11 @@ Number of log records failed to be unmarshaled ### otelcol_kafka_receiver_unmarshal_failed_metric_points -Number of metric points failed to be unmarshaled +Number of metric points failed to be unmarshaled [development] -| Unit | Metric Type | Value Type | Monotonic | -| ---- | ----------- | ---------- | --------- | -| 1 | Sum | Int | true | +| Unit | Metric Type | Value Type | Monotonic | Stability | +| ---- | ----------- | ---------- | --------- | --------- | +| 1 | Sum | Int | true | development | #### Attributes @@ -280,11 +280,11 @@ Number of metric points failed to be unmarshaled ### otelcol_kafka_receiver_unmarshal_failed_profiles -Number of profiles failed to be unmarshaled +Number of profiles failed to be unmarshaled [development] -| Unit | Metric Type | Value Type | Monotonic | -| ---- | ----------- | ---------- | --------- | -| 1 | Sum | Int | true | +| Unit | Metric Type | Value Type | Monotonic | Stability | +| ---- | ----------- | ---------- | --------- | --------- | +| 1 | Sum | Int | true | development | #### Attributes @@ -295,11 +295,11 @@ Number of profiles failed to be unmarshaled ### otelcol_kafka_receiver_unmarshal_failed_spans -Number of spans failed to be unmarshaled +Number of spans failed to be unmarshaled [development] -| Unit | Metric Type | Value Type | Monotonic | -| ---- | ----------- | ---------- | --------- | -| 1 | Sum | Int | true | +| Unit | Metric Type | Value Type | Monotonic | Stability | +| ---- | ----------- | ---------- | --------- | --------- | +| 1 | Sum | Int | true | development | #### Attributes diff --git a/receiver/kafkareceiver/internal/metadata/generated_telemetry.go b/receiver/kafkareceiver/internal/metadata/generated_telemetry.go index 9d56a3fbc556d..18f4f1980ebaf 100644 --- a/receiver/kafkareceiver/internal/metadata/generated_telemetry.go +++ b/receiver/kafkareceiver/internal/metadata/generated_telemetry.go @@ -78,13 +78,13 @@ func NewTelemetryBuilder(settings component.TelemetrySettings, options ...Teleme var err, errs error builder.KafkaBrokerClosed, err = builder.meter.Int64Counter( "otelcol_kafka_broker_closed", - metric.WithDescription("The total number of connections closed."), + metric.WithDescription("The total number of connections closed. [development]"), metric.WithUnit("1"), ) errs = errors.Join(errs, err) builder.KafkaBrokerConnects, err = builder.meter.Int64Counter( "otelcol_kafka_broker_connects", - metric.WithDescription("The total number of connections opened."), + metric.WithDescription("The total number of connections opened. [development]"), metric.WithUnit("1"), ) errs = errors.Join(errs, err) @@ -96,26 +96,26 @@ func NewTelemetryBuilder(settings component.TelemetrySettings, options ...Teleme errs = errors.Join(errs, err) builder.KafkaBrokerThrottlingLatency, err = builder.meter.Float64Histogram( "otelcol_kafka_broker_throttling_latency", - metric.WithDescription("The throttling latency in seconds imposed by the broker when receiving records."), + metric.WithDescription("The throttling latency in seconds imposed by the broker when receiving records. [development]"), metric.WithUnit("s"), metric.WithExplicitBucketBoundaries([]float64{0, 0.005, 0.01, 0.025, 0.05, 0.075, 0.1, 0.25, 0.5, 0.75, 1, 2.5, 5, 7.5, 10, 25, 50, 75, 100}...), ) errs = errors.Join(errs, err) builder.KafkaReceiverBytes, err = builder.meter.Int64Counter( "otelcol_kafka_receiver_bytes", - metric.WithDescription("The size in bytes of received records seen by the broker."), + metric.WithDescription("The size in bytes of received records seen by the broker. [development]"), metric.WithUnit("By"), ) errs = errors.Join(errs, err) builder.KafkaReceiverBytesUncompressed, err = builder.meter.Int64Counter( "otelcol_kafka_receiver_bytes_uncompressed", - metric.WithDescription("The uncompressed size in bytes of received records seen by the client."), + metric.WithDescription("The uncompressed size in bytes of received records seen by the client. [development]"), metric.WithUnit("By"), ) errs = errors.Join(errs, err) builder.KafkaReceiverCurrentOffset, err = builder.meter.Int64Gauge( "otelcol_kafka_receiver_current_offset", - metric.WithDescription("Current message offset"), + metric.WithDescription("Current message offset [development]"), metric.WithUnit("1"), ) errs = errors.Join(errs, err) @@ -133,63 +133,63 @@ func NewTelemetryBuilder(settings component.TelemetrySettings, options ...Teleme errs = errors.Join(errs, err) builder.KafkaReceiverOffsetLag, err = builder.meter.Int64Gauge( "otelcol_kafka_receiver_offset_lag", - metric.WithDescription("Current offset lag"), + metric.WithDescription("Current offset lag [development]"), metric.WithUnit("1"), ) errs = errors.Join(errs, err) builder.KafkaReceiverPartitionClose, err = builder.meter.Int64Counter( "otelcol_kafka_receiver_partition_close", - metric.WithDescription("Number of finished partitions"), + metric.WithDescription("Number of finished partitions [development]"), metric.WithUnit("1"), ) errs = errors.Join(errs, err) builder.KafkaReceiverPartitionStart, err = builder.meter.Int64Counter( "otelcol_kafka_receiver_partition_start", - metric.WithDescription("Number of started partitions"), + metric.WithDescription("Number of started partitions [development]"), metric.WithUnit("1"), ) errs = errors.Join(errs, err) builder.KafkaReceiverReadLatency, err = builder.meter.Float64Histogram( "otelcol_kafka_receiver_read_latency", - metric.WithDescription("The time it took in seconds to receive a batch of records."), + metric.WithDescription("The time it took in seconds to receive a batch of records. [development]"), metric.WithUnit("s"), metric.WithExplicitBucketBoundaries([]float64{0, 0.005, 0.01, 0.025, 0.05, 0.075, 0.1, 0.25, 0.5, 0.75, 1, 2.5, 5, 7.5, 10, 25, 50, 75, 100}...), ) errs = errors.Join(errs, err) builder.KafkaReceiverRecords, err = builder.meter.Int64Counter( "otelcol_kafka_receiver_records", - metric.WithDescription("The number of received records."), + metric.WithDescription("The number of received records. [development]"), metric.WithUnit("1"), ) errs = errors.Join(errs, err) builder.KafkaReceiverRecordsDelay, err = builder.meter.Float64Histogram( "otelcol_kafka_receiver_records_delay", - metric.WithDescription("The time in seconds between producing and receiving a batch of records."), + metric.WithDescription("The time in seconds between producing and receiving a batch of records. [development]"), metric.WithUnit("s"), metric.WithExplicitBucketBoundaries([]float64{0, 0.005, 0.01, 0.025, 0.05, 0.075, 0.1, 0.25, 0.5, 0.75, 1, 2.5, 5, 7.5, 10, 25, 50, 75, 100, 250, 500, 750, 1000, 2500, 5000, 7500, 10000}...), ) errs = errors.Join(errs, err) builder.KafkaReceiverUnmarshalFailedLogRecords, err = builder.meter.Int64Counter( "otelcol_kafka_receiver_unmarshal_failed_log_records", - metric.WithDescription("Number of log records failed to be unmarshaled"), + metric.WithDescription("Number of log records failed to be unmarshaled [development]"), metric.WithUnit("1"), ) errs = errors.Join(errs, err) builder.KafkaReceiverUnmarshalFailedMetricPoints, err = builder.meter.Int64Counter( "otelcol_kafka_receiver_unmarshal_failed_metric_points", - metric.WithDescription("Number of metric points failed to be unmarshaled"), + metric.WithDescription("Number of metric points failed to be unmarshaled [development]"), metric.WithUnit("1"), ) errs = errors.Join(errs, err) builder.KafkaReceiverUnmarshalFailedProfiles, err = builder.meter.Int64Counter( "otelcol_kafka_receiver_unmarshal_failed_profiles", - metric.WithDescription("Number of profiles failed to be unmarshaled"), + metric.WithDescription("Number of profiles failed to be unmarshaled [development]"), metric.WithUnit("1"), ) errs = errors.Join(errs, err) builder.KafkaReceiverUnmarshalFailedSpans, err = builder.meter.Int64Counter( "otelcol_kafka_receiver_unmarshal_failed_spans", - metric.WithDescription("Number of spans failed to be unmarshaled"), + metric.WithDescription("Number of spans failed to be unmarshaled [development]"), metric.WithUnit("1"), ) errs = errors.Join(errs, err) diff --git a/receiver/kafkareceiver/internal/metadatatest/generated_telemetrytest.go b/receiver/kafkareceiver/internal/metadatatest/generated_telemetrytest.go index 7236a563a5cc9..94a6aacd5a177 100644 --- a/receiver/kafkareceiver/internal/metadatatest/generated_telemetrytest.go +++ b/receiver/kafkareceiver/internal/metadatatest/generated_telemetrytest.go @@ -24,7 +24,7 @@ func NewSettings(tt *componenttest.Telemetry) receiver.Settings { func AssertEqualKafkaBrokerClosed(t *testing.T, tt *componenttest.Telemetry, dps []metricdata.DataPoint[int64], opts ...metricdatatest.Option) { want := metricdata.Metrics{ Name: "otelcol_kafka_broker_closed", - Description: "The total number of connections closed.", + Description: "The total number of connections closed. [development]", Unit: "1", Data: metricdata.Sum[int64]{ Temporality: metricdata.CumulativeTemporality, @@ -40,7 +40,7 @@ func AssertEqualKafkaBrokerClosed(t *testing.T, tt *componenttest.Telemetry, dps func AssertEqualKafkaBrokerConnects(t *testing.T, tt *componenttest.Telemetry, dps []metricdata.DataPoint[int64], opts ...metricdatatest.Option) { want := metricdata.Metrics{ Name: "otelcol_kafka_broker_connects", - Description: "The total number of connections opened.", + Description: "The total number of connections opened. [development]", Unit: "1", Data: metricdata.Sum[int64]{ Temporality: metricdata.CumulativeTemporality, @@ -71,7 +71,7 @@ func AssertEqualKafkaBrokerThrottlingDuration(t *testing.T, tt *componenttest.Te func AssertEqualKafkaBrokerThrottlingLatency(t *testing.T, tt *componenttest.Telemetry, dps []metricdata.HistogramDataPoint[float64], opts ...metricdatatest.Option) { want := metricdata.Metrics{ Name: "otelcol_kafka_broker_throttling_latency", - Description: "The throttling latency in seconds imposed by the broker when receiving records.", + Description: "The throttling latency in seconds imposed by the broker when receiving records. [development]", Unit: "s", Data: metricdata.Histogram[float64]{ Temporality: metricdata.CumulativeTemporality, @@ -86,7 +86,7 @@ func AssertEqualKafkaBrokerThrottlingLatency(t *testing.T, tt *componenttest.Tel func AssertEqualKafkaReceiverBytes(t *testing.T, tt *componenttest.Telemetry, dps []metricdata.DataPoint[int64], opts ...metricdatatest.Option) { want := metricdata.Metrics{ Name: "otelcol_kafka_receiver_bytes", - Description: "The size in bytes of received records seen by the broker.", + Description: "The size in bytes of received records seen by the broker. [development]", Unit: "By", Data: metricdata.Sum[int64]{ Temporality: metricdata.CumulativeTemporality, @@ -102,7 +102,7 @@ func AssertEqualKafkaReceiverBytes(t *testing.T, tt *componenttest.Telemetry, dp func AssertEqualKafkaReceiverBytesUncompressed(t *testing.T, tt *componenttest.Telemetry, dps []metricdata.DataPoint[int64], opts ...metricdatatest.Option) { want := metricdata.Metrics{ Name: "otelcol_kafka_receiver_bytes_uncompressed", - Description: "The uncompressed size in bytes of received records seen by the client.", + Description: "The uncompressed size in bytes of received records seen by the client. [development]", Unit: "By", Data: metricdata.Sum[int64]{ Temporality: metricdata.CumulativeTemporality, @@ -118,7 +118,7 @@ func AssertEqualKafkaReceiverBytesUncompressed(t *testing.T, tt *componenttest.T func AssertEqualKafkaReceiverCurrentOffset(t *testing.T, tt *componenttest.Telemetry, dps []metricdata.DataPoint[int64], opts ...metricdatatest.Option) { want := metricdata.Metrics{ Name: "otelcol_kafka_receiver_current_offset", - Description: "Current message offset", + Description: "Current message offset [development]", Unit: "1", Data: metricdata.Gauge[int64]{ DataPoints: dps, @@ -163,7 +163,7 @@ func AssertEqualKafkaReceiverMessages(t *testing.T, tt *componenttest.Telemetry, func AssertEqualKafkaReceiverOffsetLag(t *testing.T, tt *componenttest.Telemetry, dps []metricdata.DataPoint[int64], opts ...metricdatatest.Option) { want := metricdata.Metrics{ Name: "otelcol_kafka_receiver_offset_lag", - Description: "Current offset lag", + Description: "Current offset lag [development]", Unit: "1", Data: metricdata.Gauge[int64]{ DataPoints: dps, @@ -177,7 +177,7 @@ func AssertEqualKafkaReceiverOffsetLag(t *testing.T, tt *componenttest.Telemetry func AssertEqualKafkaReceiverPartitionClose(t *testing.T, tt *componenttest.Telemetry, dps []metricdata.DataPoint[int64], opts ...metricdatatest.Option) { want := metricdata.Metrics{ Name: "otelcol_kafka_receiver_partition_close", - Description: "Number of finished partitions", + Description: "Number of finished partitions [development]", Unit: "1", Data: metricdata.Sum[int64]{ Temporality: metricdata.CumulativeTemporality, @@ -193,7 +193,7 @@ func AssertEqualKafkaReceiverPartitionClose(t *testing.T, tt *componenttest.Tele func AssertEqualKafkaReceiverPartitionStart(t *testing.T, tt *componenttest.Telemetry, dps []metricdata.DataPoint[int64], opts ...metricdatatest.Option) { want := metricdata.Metrics{ Name: "otelcol_kafka_receiver_partition_start", - Description: "Number of started partitions", + Description: "Number of started partitions [development]", Unit: "1", Data: metricdata.Sum[int64]{ Temporality: metricdata.CumulativeTemporality, @@ -209,7 +209,7 @@ func AssertEqualKafkaReceiverPartitionStart(t *testing.T, tt *componenttest.Tele func AssertEqualKafkaReceiverReadLatency(t *testing.T, tt *componenttest.Telemetry, dps []metricdata.HistogramDataPoint[float64], opts ...metricdatatest.Option) { want := metricdata.Metrics{ Name: "otelcol_kafka_receiver_read_latency", - Description: "The time it took in seconds to receive a batch of records.", + Description: "The time it took in seconds to receive a batch of records. [development]", Unit: "s", Data: metricdata.Histogram[float64]{ Temporality: metricdata.CumulativeTemporality, @@ -224,7 +224,7 @@ func AssertEqualKafkaReceiverReadLatency(t *testing.T, tt *componenttest.Telemet func AssertEqualKafkaReceiverRecords(t *testing.T, tt *componenttest.Telemetry, dps []metricdata.DataPoint[int64], opts ...metricdatatest.Option) { want := metricdata.Metrics{ Name: "otelcol_kafka_receiver_records", - Description: "The number of received records.", + Description: "The number of received records. [development]", Unit: "1", Data: metricdata.Sum[int64]{ Temporality: metricdata.CumulativeTemporality, @@ -240,7 +240,7 @@ func AssertEqualKafkaReceiverRecords(t *testing.T, tt *componenttest.Telemetry, func AssertEqualKafkaReceiverRecordsDelay(t *testing.T, tt *componenttest.Telemetry, dps []metricdata.HistogramDataPoint[float64], opts ...metricdatatest.Option) { want := metricdata.Metrics{ Name: "otelcol_kafka_receiver_records_delay", - Description: "The time in seconds between producing and receiving a batch of records.", + Description: "The time in seconds between producing and receiving a batch of records. [development]", Unit: "s", Data: metricdata.Histogram[float64]{ Temporality: metricdata.CumulativeTemporality, @@ -255,7 +255,7 @@ func AssertEqualKafkaReceiverRecordsDelay(t *testing.T, tt *componenttest.Teleme func AssertEqualKafkaReceiverUnmarshalFailedLogRecords(t *testing.T, tt *componenttest.Telemetry, dps []metricdata.DataPoint[int64], opts ...metricdatatest.Option) { want := metricdata.Metrics{ Name: "otelcol_kafka_receiver_unmarshal_failed_log_records", - Description: "Number of log records failed to be unmarshaled", + Description: "Number of log records failed to be unmarshaled [development]", Unit: "1", Data: metricdata.Sum[int64]{ Temporality: metricdata.CumulativeTemporality, @@ -271,7 +271,7 @@ func AssertEqualKafkaReceiverUnmarshalFailedLogRecords(t *testing.T, tt *compone func AssertEqualKafkaReceiverUnmarshalFailedMetricPoints(t *testing.T, tt *componenttest.Telemetry, dps []metricdata.DataPoint[int64], opts ...metricdatatest.Option) { want := metricdata.Metrics{ Name: "otelcol_kafka_receiver_unmarshal_failed_metric_points", - Description: "Number of metric points failed to be unmarshaled", + Description: "Number of metric points failed to be unmarshaled [development]", Unit: "1", Data: metricdata.Sum[int64]{ Temporality: metricdata.CumulativeTemporality, @@ -287,7 +287,7 @@ func AssertEqualKafkaReceiverUnmarshalFailedMetricPoints(t *testing.T, tt *compo func AssertEqualKafkaReceiverUnmarshalFailedProfiles(t *testing.T, tt *componenttest.Telemetry, dps []metricdata.DataPoint[int64], opts ...metricdatatest.Option) { want := metricdata.Metrics{ Name: "otelcol_kafka_receiver_unmarshal_failed_profiles", - Description: "Number of profiles failed to be unmarshaled", + Description: "Number of profiles failed to be unmarshaled [development]", Unit: "1", Data: metricdata.Sum[int64]{ Temporality: metricdata.CumulativeTemporality, @@ -303,7 +303,7 @@ func AssertEqualKafkaReceiverUnmarshalFailedProfiles(t *testing.T, tt *component func AssertEqualKafkaReceiverUnmarshalFailedSpans(t *testing.T, tt *componenttest.Telemetry, dps []metricdata.DataPoint[int64], opts ...metricdatatest.Option) { want := metricdata.Metrics{ Name: "otelcol_kafka_receiver_unmarshal_failed_spans", - Description: "Number of spans failed to be unmarshaled", + Description: "Number of spans failed to be unmarshaled [development]", Unit: "1", Data: metricdata.Sum[int64]{ Temporality: metricdata.CumulativeTemporality, diff --git a/receiver/kafkareceiver/metadata.yaml b/receiver/kafkareceiver/metadata.yaml index 1489083276934..6eadcddf36ed0 100644 --- a/receiver/kafkareceiver/metadata.yaml +++ b/receiver/kafkareceiver/metadata.yaml @@ -41,6 +41,8 @@ telemetry: description: The total number of connections opened. extended_documentation: Only produced when franz-go is enabled. optional: true + stability: + level: development unit: "1" sum: value_type: int @@ -51,6 +53,8 @@ telemetry: description: The total number of connections closed. extended_documentation: Only produced when franz-go is enabled. optional: true + stability: + level: development unit: "1" sum: value_type: int @@ -74,6 +78,8 @@ telemetry: description: The throttling latency in seconds imposed by the broker when receiving records. extended_documentation: Only produced when franz-go is enabled. optional: true + stability: + level: development unit: s histogram: value_type: double @@ -95,6 +101,8 @@ telemetry: kafka_receiver_records: enabled: true description: The number of received records. + stability: + level: development unit: "1" sum: value_type: int @@ -105,6 +113,8 @@ telemetry: description: The size in bytes of received records seen by the broker. extended_documentation: Only produced when franz-go is enabled. optional: true + stability: + level: development unit: By sum: value_type: int @@ -113,6 +123,8 @@ telemetry: kafka_receiver_bytes_uncompressed: enabled: true description: The uncompressed size in bytes of received records seen by the client. + stability: + level: development unit: By sum: value_type: int @@ -134,6 +146,8 @@ telemetry: enabled: true description: The time it took in seconds to receive a batch of records. extended_documentation: Only produced when franz-go is enabled. + stability: + level: development unit: s histogram: value_type: double @@ -148,6 +162,8 @@ telemetry: Note that this metric may slow down high-volume consuming. Only produced when franz-go is enabled. This metric is reported with an assumption that the exporter and the receiver clocks are synchronized. + stability: + level: development unit: s histogram: value_type: double @@ -156,6 +172,8 @@ telemetry: kafka_receiver_current_offset: enabled: true description: Current message offset + stability: + level: development unit: "1" gauge: value_type: int @@ -163,6 +181,8 @@ telemetry: kafka_receiver_offset_lag: enabled: true description: Current offset lag + stability: + level: development unit: "1" gauge: value_type: int @@ -170,6 +190,8 @@ telemetry: kafka_receiver_partition_start: enabled: true description: Number of started partitions + stability: + level: development unit: "1" sum: value_type: int @@ -177,6 +199,8 @@ telemetry: kafka_receiver_partition_close: enabled: true description: Number of finished partitions + stability: + level: development unit: "1" sum: value_type: int @@ -184,6 +208,8 @@ telemetry: kafka_receiver_unmarshal_failed_metric_points: enabled: true description: Number of metric points failed to be unmarshaled + stability: + level: development unit: "1" sum: value_type: int @@ -192,6 +218,8 @@ telemetry: kafka_receiver_unmarshal_failed_log_records: enabled: true description: Number of log records failed to be unmarshaled + stability: + level: development unit: "1" sum: value_type: int @@ -200,6 +228,8 @@ telemetry: kafka_receiver_unmarshal_failed_spans: enabled: true description: Number of spans failed to be unmarshaled + stability: + level: development unit: "1" sum: value_type: int @@ -208,6 +238,8 @@ telemetry: kafka_receiver_unmarshal_failed_profiles: enabled: true description: Number of profiles failed to be unmarshaled + stability: + level: development unit: "1" sum: value_type: int