-
Notifications
You must be signed in to change notification settings - Fork 969
feat(kafka-clients): add messaging.kafka.bootstrap.servers
attribute
#14032
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
base: main
Are you sure you want to change the base?
Conversation
- Add VirtualFieldStore for managing bootstrap servers storage - Instrument KafkaConsumer and KafkaProducer constructors - Include bootstrap.servers attribute in all relevant spans Addresses part of open-telemetry#14031 open-telemetry#10647
- library instrumentation test
🔧 The result from spotlessApply was committed to the PR branch. |
Hi @laurit , Could you review this PR? Thanks! |
Thanks! It would be nice if the new attribute would be proposed in https://github.com/open-telemetry/semantic-conventions/blob/main/docs/messaging/kafka.md as well...just sayin'. |
...try/instrumentation/kafkaclients/common/v0_11/internal/KafkaProducerAttributesExtractor.java
Outdated
Show resolved
Hide resolved
...opentelemetry/javaagent/instrumentation/kafkaclients/v0_11/KafkaProducerInstrumentation.java
Outdated
Show resolved
Hide resolved
Thanks for the suggestion! I will first place this attribute in |
...opentelemetry/javaagent/instrumentation/kafkaclients/v0_11/KafkaConsumerInstrumentation.java
Outdated
Show resolved
Hide resolved
...opentelemetry/javaagent/instrumentation/kafkaclients/v0_11/KafkaConsumerInstrumentation.java
Outdated
Show resolved
Hide resolved
...opentelemetry/javaagent/instrumentation/kafkaclients/v0_11/KafkaConsumerInstrumentation.java
Outdated
Show resolved
Hide resolved
...try/instrumentation/kafkaclients/common/v0_11/internal/KafkaConsumerAttributesExtractor.java
Outdated
Show resolved
Hide resolved
Hi @laurit ,May I ask what should be done about the failures in the |
you can ignore these failures, they will not hold up review or merging |
bootstrap.servers
through constructor instrumentationbootstrap.servers
through reflection and kafka-clients interceptorsbootstrap servers
storage#14031 #10647