Skip to content

Commit d984273

Browse files
amarzialimcculls
andauthored
Update dd-java-agent/instrumentation/kafka/kafka-clients-3.8/src/main/java17/datadog/trace/instrumentation/kafka_clients38/TracingIterator.java
Co-authored-by: Stuart McCulloch <stuart.mcculloch@datadoghq.com>
1 parent fe3bb04 commit d984273

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

  • dd-java-agent/instrumentation/kafka/kafka-clients-3.8/src/main/java17/datadog/trace/instrumentation/kafka_clients38

dd-java-agent/instrumentation/kafka/kafka-clients-3.8/src/main/java17/datadog/trace/instrumentation/kafka_clients38/TracingIterator.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -87,7 +87,7 @@ protected void startNewRecordSpan(ConsumerRecord<?, ?> val) {
8787
try {
8888
if (InstrumenterConfig.get().isLegacyContextManagerEnabled()) {
8989
closePrevious(true);
90-
} else {
90+
} else if (val == null) { // previous message span was the last
9191
final AgentSpan previousSpan = spanFromContext(getRootContext().swap());
9292
if (previousSpan != null) {
9393
previousSpan.finishWithEndToEnd();

0 commit comments

Comments
 (0)