Skip to content

Commit f7d09db

Browse files
add fake Kafka change
1 parent e5cd515 commit f7d09db

File tree

1 file changed

+6
-3
lines changed
  • dd-java-agent/instrumentation/kafka-clients-0.11/src/main/java/datadog/trace/instrumentation/kafka_clients

1 file changed

+6
-3
lines changed

dd-java-agent/instrumentation/kafka-clients-0.11/src/main/java/datadog/trace/instrumentation/kafka_clients/KafkaDecorator.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -165,10 +165,13 @@ public void onProduce(
165165

166166

167167
try {
168-
System.out.println("Before sleep for 1ms Rob kafkaClient011");
169-
Thread.sleep(1);
168+
System.out.println("Before empty work Rob kafkaClient011");
169+
int x = 0;
170+
for (int i = 0; i < 1000; i++) {
171+
x++; // Prevent JIT optimization
172+
}
170173
// Sleep to avoid race conditions between topology updates
171-
System.out.println("Sleeping for 1ms Rob");
174+
System.out.println("After empty work Rob");
172175
} catch (InterruptedException e) {
173176
Thread.currentThread().interrupt();
174177
}

0 commit comments

Comments
 (0)