- 
                Notifications
    
You must be signed in to change notification settings  - Fork 1k
 
          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
        
      Co-authored-by: jason plumb <[email protected]>
          
 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.serversthrough constructor instrumentationbootstrap.serversthrough reflection and kafka-clients interceptorsbootstrap serversstorage#14031 #10647