open-telemetry
/
opentelemetry-java-instrumentation
mirror of https://github.com/open-telemetry/opentelemetry-java-instrumentation.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add note about Kafka consumer iterator thread safety

This commit is contained in:
Nikolay Martynov 2019-05-24 16:37:27 -04:00
parent a3a325868c
commit ef94e2fb79
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
dd-java-agent/instrumentation/kafka-clients-0.11/src/main/java/datadog/trace/instrumentation/kafka_clients/TracingIterable.java
View File

@ -33,6 +33,10 @@ public class TracingIterable implements Iterable<ConsumerRecord> {
private final String operationName; private final String operationName;
private final KafkaDecorator decorator; private final KafkaDecorator decorator;
/**
* Note: this may potentially create problems if this iterator is used from different threads.
* But at the moment we cannot do much about this.
*/
private Scope currentScope; private Scope currentScope;
public TracingIterator( public TracingIterator(