Skip to content

Commit f8e3d6c

Browse files
committed
Update registry inventory
1 parent 447a22c commit f8e3d6c

2 files changed

Lines changed: 54 additions & 6 deletions

File tree

ecosystem-registry/collector/contrib/v0.154.1-SNAPSHOT/receiver.yaml

Lines changed: 16 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -262,6 +262,21 @@ components:
262262
aggregation_temporality: cumulative
263263
value_type: int
264264
stability: development
265+
- name: activedirectoryinvreceiver
266+
metadata:
267+
type: active_directory_inv
268+
status:
269+
class: receiver
270+
stability:
271+
alpha:
272+
- logs
273+
distributions:
274+
- contrib
275+
codeowners:
276+
active:
277+
- pjanotti
278+
- pankaj101A
279+
- jagan2221
265280
- name: aerospikereceiver
266281
metadata:
267282
type: aerospike
@@ -4410,7 +4425,7 @@ components:
44104425
type: string
44114426
- name: flinkmetricsreceiver
44124427
metadata:
4413-
type: flinkmetrics
4428+
type: flink_metrics
44144429
display_name: FlinkMetrics Receiver
44154430
description: This receiver uses Flink's [REST API](https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/ops/metrics/#rest-api-integration)
44164431
to collect Jobmanager, Taskmanager, Job, Task and Operator metrics.

ecosystem-registry/java/javaagent/v2.28.2-SNAPSHOT/library_readmes/spring-kafka-2.7-21188e4ea0dc.md renamed to ecosystem-registry/java/javaagent/v2.28.2-SNAPSHOT/library_readmes/spring-kafka-2.7-b6cf57901b0f.md

Lines changed: 38 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -32,28 +32,61 @@ implementation("io.opentelemetry.instrumentation:opentelemetry-spring-kafka-2.7:
3232
The instrumentation library provides interceptors that can be added to Spring Kafka message
3333
listener containers and producers to provide spans and context propagation.
3434

35+
For Spring Boot 2.x and 3.x, instrument producers with:
36+
3537
```java
3638
import io.opentelemetry.api.OpenTelemetry;
3739
import io.opentelemetry.instrumentation.kafkaclients.v2_6.KafkaTelemetry;
38-
import io.opentelemetry.instrumentation.spring.kafka.v2_7.SpringKafkaTelemetry;
3940
import org.springframework.boot.autoconfigure.kafka.DefaultKafkaProducerFactoryCustomizer;
4041
import org.springframework.context.annotation.Bean;
4142
import org.springframework.context.annotation.Configuration;
42-
import org.springframework.kafka.config.ContainerCustomizer;
43-
import org.springframework.kafka.listener.ConcurrentMessageListenerContainer;
4443

4544
@Configuration
4645
public class KafkaInstrumentationConfig {
4746

48-
// Instrument Kafka producers
4947
@Bean
5048
public DefaultKafkaProducerFactoryCustomizer producerInstrumentation(
5149
OpenTelemetry openTelemetry) {
5250
KafkaTelemetry kafkaTelemetry = KafkaTelemetry.create(openTelemetry);
5351
return producerFactory -> producerFactory.addPostProcessor(kafkaTelemetry::wrap);
5452
}
53+
}
54+
```
55+
56+
For Spring Boot 4.x, use the new package for the same customizer:
57+
58+
```java
59+
import io.opentelemetry.api.OpenTelemetry;
60+
import io.opentelemetry.instrumentation.kafkaclients.v2_6.KafkaTelemetry;
61+
import org.springframework.boot.kafka.autoconfigure.DefaultKafkaProducerFactoryCustomizer;
62+
import org.springframework.context.annotation.Bean;
63+
import org.springframework.context.annotation.Configuration;
64+
65+
@Configuration
66+
public class KafkaInstrumentationConfig {
67+
68+
@Bean
69+
public DefaultKafkaProducerFactoryCustomizer producerInstrumentation(
70+
OpenTelemetry openTelemetry) {
71+
KafkaTelemetry kafkaTelemetry = KafkaTelemetry.create(openTelemetry);
72+
return producerFactory -> producerFactory.addPostProcessor(kafkaTelemetry::wrap);
73+
}
74+
}
75+
```
76+
77+
Instrument consumers with:
78+
79+
```java
80+
import io.opentelemetry.api.OpenTelemetry;
81+
import io.opentelemetry.instrumentation.spring.kafka.v2_7.SpringKafkaTelemetry;
82+
import org.springframework.context.annotation.Bean;
83+
import org.springframework.context.annotation.Configuration;
84+
import org.springframework.kafka.config.ContainerCustomizer;
85+
import org.springframework.kafka.listener.ConcurrentMessageListenerContainer;
86+
87+
@Configuration
88+
public class KafkaInstrumentationConfig {
5589

56-
// Instrument Kafka consumers
5790
@Bean
5891
public ContainerCustomizer<String, String, ConcurrentMessageListenerContainer<String, String>>
5992
listenerCustomizer(OpenTelemetry openTelemetry) {

0 commit comments

Comments
 (0)