Fixed kafka produce extractor error by kr-igor · Pull Request #10610 · DataDog/dd-trace-java

kr-igor · 2026-02-17T17:43:12Z

What Does This Do

Fixes a bug when the record was passed to extractor instead of headers.

Motivation

Kafka Produce extractors currently fails with:

java.lang.ClassCastException: class org.apache.kafka.clients.producer.ProducerRecord cannot be cast to class
  org.apache.kafka.common.header.Headers (org.apache.kafka.clients.producer.ProducerRecord and org.apache.kafka.common.header.Headers
   are in unnamed module of loader org.springframework.boot.loader.LaunchedURLClassLoader @30c0d731)
        at datadog.trace.instrumentation.kafka_common.Utils.lambda$static$0(Utils.java:14)
        at datadog.trace.agent.core.datastreams.DefaultDataStreamsMonitoring.trackTransaction(DefaultDataStreamsMonitoring.java:227)
        at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:884)
        at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:773)
        at datadog.dsm.tests.GenericService.sendToKafka(GenericService.java:344)
        at datadog.dsm.tests.GenericService.sendMessage(GenericService.java:306)
        at datadog.dsm.tests.GenericService.runProducer(GenericService.java:158)
        at datadog.dsm.tests.GenericService.main(GenericService.java:126)
        at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
        at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
        at java.base/java.lang.reflect.Method.invoke(Unknown Source)
        at org.springframework.boot.loader.MainMethodRunner.run(MainMethodRunner.java:49)
        at org.springframework.boot.loader.Launcher.launch(Launcher.java:108)
        at org.springframework.boot.loader.Launcher.launch(Launcher.java:58)
        at org.springframework.boot.loader.JarLauncher.main(JarLauncher.java:88)

github-actions · 2026-02-17T17:43:23Z

Hi! 👋 Thanks for your pull request! 🎉

To help us review it, please make sure to:

Add at least one type, and one component or instrumentation label to the pull request

If you need help, please check our contributing guidelines.

pr-commenter · 2026-02-17T18:20:08Z

Kafka / producer-benchmark

Parameters

	Baseline	Candidate
baseline_or_candidate	baseline	candidate
git_branch	master	kr-igor/fix-kafka-extractor
git_commit_date	1771346510	1771365821
git_commit_sha	`405276a`	`7910457`

See matching parameters

	Baseline	Candidate
ci_job_date	1771367016	1771367016
ci_job_id	1433685200	1433685200
ci_pipeline_id	97073793	97073793
cpu_model	Intel(R) Xeon(R) Platinum 8259CL CPU @ 2.50GHz	Intel(R) Xeon(R) Platinum 8259CL CPU @ 2.50GHz
jdkVersion	11.0.25	11.0.25
jmhVersion	1.36	1.36
jvm	/usr/lib/jvm/java-11-openjdk-amd64/bin/java	/usr/lib/jvm/java-11-openjdk-amd64/bin/java
jvmArgs	-Dfile.encoding=UTF-8 -Djava.io.tmpdir=/go/src/github.com/DataDog/apm-reliability/dd-trace-java/platform/src/producer-benchmark/build/tmp/jmh -Duser.country=US -Duser.language=en -Duser.variant	-Dfile.encoding=UTF-8 -Djava.io.tmpdir=/go/src/github.com/DataDog/apm-reliability/dd-trace-java/platform/src/producer-benchmark/build/tmp/jmh -Duser.country=US -Duser.language=en -Duser.variant
vmName	OpenJDK 64-Bit Server VM	OpenJDK 64-Bit Server VM
vmVersion	11.0.25+9-post-Ubuntu-1ubuntu122.04	11.0.25+9-post-Ubuntu-1ubuntu122.04

Summary

Found 0 performance improvements and 0 performance regressions! Performance is the same for 3 metrics, 0 unstable metrics.

See unchanged results

scenario	Δ mean throughput
scenario:not-instrumented/KafkaProduceBenchmark.benchProduce	same
scenario:only-tracing-dsm-disabled-benchmarks/KafkaProduceBenchmark.benchProduce	same
scenario:only-tracing-dsm-enabled-benchmarks/KafkaProduceBenchmark.benchProduce	same

pr-commenter · 2026-02-17T18:27:35Z

Benchmarks

Startup

Parameters

	Baseline	Candidate
baseline_or_candidate	baseline	candidate
git_branch	master	kr-igor/fix-kafka-extractor
git_commit_date	1771346510	1771365821
git_commit_sha	`405276a`	`7910457`
release_version	1.60.0-SNAPSHOT~405276aea3	1.60.0-SNAPSHOT~791045757c

See matching parameters

	Baseline	Candidate
application	insecure-bank	insecure-bank
ci_job_date	1771367726	1771367726
ci_job_id	1433685195	1433685195
ci_pipeline_id	97073793	97073793
cpu_model	Intel(R) Xeon(R) Platinum 8259CL CPU @ 2.50GHz	Intel(R) Xeon(R) Platinum 8259CL CPU @ 2.50GHz
kernel_version	Linux runner-zfyrx7zua-project-304-concurrent-0-v8ufw03l 6.8.0-1031-aws #33~22.04.1-Ubuntu SMP Thu Jun 26 14:22:30 UTC 2025 x86_64 x86_64 x86_64 GNU/Linux	Linux runner-zfyrx7zua-project-304-concurrent-0-v8ufw03l 6.8.0-1031-aws #33~22.04.1-Ubuntu SMP Thu Jun 26 14:22:30 UTC 2025 x86_64 x86_64 x86_64 GNU/Linux
module	Agent	Agent
parent	None	None

Summary

Found 0 performance improvements and 0 performance regressions! Performance is the same for 64 metrics, 7 unstable metrics.

Startup time reports for petclinic

gantt
    title petclinic - global startup overhead: candidate=1.60.0-SNAPSHOT~791045757c, baseline=1.60.0-SNAPSHOT~405276aea3

    dateFormat X
    axisFormat %s
section tracing
Agent [baseline] (1.067 s) : 0, 1066953
Total [baseline] (10.92 s) : 0, 10919997
Agent [candidate] (1.068 s) : 0, 1068245
Total [candidate] (10.78 s) : 0, 10780123
section appsec
Agent [baseline] (1.239 s) : 0, 1239101
Total [baseline] (11.025 s) : 0, 11025077
Agent [candidate] (1.24 s) : 0, 1239769
Total [candidate] (11.039 s) : 0, 11039340
section iast
Agent [baseline] (1.242 s) : 0, 1242368
Total [baseline] (11.099 s) : 0, 11099185
Agent [candidate] (1.233 s) : 0, 1232724
Total [candidate] (11.178 s) : 0, 11178155
section profiling
Agent [baseline] (1.19 s) : 0, 1190379
Total [baseline] (10.981 s) : 0, 10981125
Agent [candidate] (1.197 s) : 0, 1196970
Total [candidate] (11.015 s) : 0, 11015393

baseline results

Module	Variant	Duration	Δ tracing
Agent	tracing	1.067 s	-
Agent	appsec	1.239 s	172.148 ms (16.1%)
Agent	iast	1.242 s	175.415 ms (16.4%)
Agent	profiling	1.19 s	123.426 ms (11.6%)
Total	tracing	10.92 s	-
Total	appsec	11.025 s	105.081 ms (1.0%)
Total	iast	11.099 s	179.188 ms (1.6%)
Total	profiling	10.981 s	61.128 ms (0.6%)

candidate results

Module	Variant	Duration	Δ tracing
Agent	tracing	1.068 s	-
Agent	appsec	1.24 s	171.524 ms (16.1%)
Agent	iast	1.233 s	164.479 ms (15.4%)
Agent	profiling	1.197 s	128.726 ms (12.1%)
Total	tracing	10.78 s	-
Total	appsec	11.039 s	259.218 ms (2.4%)
Total	iast	11.178 s	398.032 ms (3.7%)
Total	profiling	11.015 s	235.27 ms (2.2%)

gantt
    title petclinic - break down per module: candidate=1.60.0-SNAPSHOT~791045757c, baseline=1.60.0-SNAPSHOT~405276aea3

    dateFormat X
    axisFormat %s
section tracing
crashtracking [baseline] (1.178 ms) : 0, 1178
crashtracking [candidate] (1.182 ms) : 0, 1182
BytebuddyAgent [baseline] (630.016 ms) : 0, 630016
BytebuddyAgent [candidate] (630.326 ms) : 0, 630326
AgentMeter [baseline] (29.03 ms) : 0, 29030
AgentMeter [candidate] (28.919 ms) : 0, 28919
GlobalTracer [baseline] (257.975 ms) : 0, 257975
GlobalTracer [candidate] (258.117 ms) : 0, 258117
AppSec [baseline] (32.871 ms) : 0, 32871
AppSec [candidate] (32.789 ms) : 0, 32789
Debugger [baseline] (63.744 ms) : 0, 63744
Debugger [candidate] (61.747 ms) : 0, 61747
Remote Config [baseline] (612.135 µs) : 0, 612
Remote Config [candidate] (646.959 µs) : 0, 647
Telemetry [baseline] (10.708 ms) : 0, 10708
Telemetry [candidate] (13.034 ms) : 0, 13034
Flare Poller [baseline] (5.413 ms) : 0, 5413
Flare Poller [candidate] (6.167 ms) : 0, 6167
section appsec
crashtracking [baseline] (1.174 ms) : 0, 1174
crashtracking [candidate] (1.174 ms) : 0, 1174
BytebuddyAgent [baseline] (658.31 ms) : 0, 658310
BytebuddyAgent [candidate] (658.465 ms) : 0, 658465
AgentMeter [baseline] (11.967 ms) : 0, 11967
AgentMeter [candidate] (11.954 ms) : 0, 11954
GlobalTracer [baseline] (257.907 ms) : 0, 257907
GlobalTracer [candidate] (258.205 ms) : 0, 258205
AppSec [baseline] (167.696 ms) : 0, 167696
AppSec [candidate] (168.022 ms) : 0, 168022
Debugger [baseline] (67.233 ms) : 0, 67233
Debugger [candidate] (67.343 ms) : 0, 67343
Remote Config [baseline] (672.019 µs) : 0, 672
Remote Config [candidate] (667.769 µs) : 0, 668
Telemetry [baseline] (9.765 ms) : 0, 9765
Telemetry [candidate] (9.693 ms) : 0, 9693
Flare Poller [baseline] (3.78 ms) : 0, 3780
Flare Poller [candidate] (3.71 ms) : 0, 3710
IAST [baseline] (25.332 ms) : 0, 25332
IAST [candidate] (25.244 ms) : 0, 25244
section iast
crashtracking [baseline] (1.183 ms) : 0, 1183
crashtracking [candidate] (1.191 ms) : 0, 1191
BytebuddyAgent [baseline] (803.187 ms) : 0, 803187
BytebuddyAgent [candidate] (796.319 ms) : 0, 796319
AgentMeter [baseline] (11.559 ms) : 0, 11559
AgentMeter [candidate] (11.276 ms) : 0, 11276
GlobalTracer [baseline] (249.677 ms) : 0, 249677
GlobalTracer [candidate] (248.273 ms) : 0, 248273
AppSec [baseline] (34.775 ms) : 0, 34775
AppSec [candidate] (32.959 ms) : 0, 32959
Debugger [baseline] (66.893 ms) : 0, 66893
Debugger [candidate] (67.93 ms) : 0, 67930
Remote Config [baseline] (545.627 µs) : 0, 546
Remote Config [candidate] (531.806 µs) : 0, 532
Telemetry [baseline] (8.574 ms) : 0, 8574
Telemetry [candidate] (8.548 ms) : 0, 8548
Flare Poller [baseline] (3.487 ms) : 0, 3487
Flare Poller [candidate] (3.429 ms) : 0, 3429
IAST [baseline] (27.106 ms) : 0, 27106
IAST [candidate] (27.036 ms) : 0, 27036
section profiling
ProfilingAgent [baseline] (99.194 ms) : 0, 99194
ProfilingAgent [candidate] (99.033 ms) : 0, 99033
crashtracking [baseline] (1.248 ms) : 0, 1248
crashtracking [candidate] (1.231 ms) : 0, 1231
BytebuddyAgent [baseline] (682.282 ms) : 0, 682282
BytebuddyAgent [candidate] (686.749 ms) : 0, 686749
AgentMeter [baseline] (8.654 ms) : 0, 8654
AgentMeter [candidate] (8.628 ms) : 0, 8628
GlobalTracer [baseline] (215.697 ms) : 0, 215697
GlobalTracer [candidate] (217.159 ms) : 0, 217159
AppSec [baseline] (32.588 ms) : 0, 32588
AppSec [candidate] (33.008 ms) : 0, 33008
Debugger [baseline] (67.4 ms) : 0, 67400
Debugger [candidate] (67.75 ms) : 0, 67750
Remote Config [baseline] (629.506 µs) : 0, 630
Remote Config [candidate] (623.432 µs) : 0, 623
Telemetry [baseline] (8.96 ms) : 0, 8960
Telemetry [candidate] (8.917 ms) : 0, 8917
Flare Poller [baseline] (3.734 ms) : 0, 3734
Flare Poller [candidate] (3.722 ms) : 0, 3722
Profiling [baseline] (99.761 ms) : 0, 99761
Profiling [candidate] (99.614 ms) : 0, 99614

Startup time reports for insecure-bank

gantt
    title insecure-bank - global startup overhead: candidate=1.60.0-SNAPSHOT~791045757c, baseline=1.60.0-SNAPSHOT~405276aea3

    dateFormat X
    axisFormat %s
section tracing
Agent [baseline] (1.064 s) : 0, 1063923
Total [baseline] (8.746 s) : 0, 8746039
Agent [candidate] (1.065 s) : 0, 1064757
Total [candidate] (8.748 s) : 0, 8747510
section iast
Agent [baseline] (1.241 s) : 0, 1240879
Total [baseline] (9.378 s) : 0, 9378390
Agent [candidate] (1.234 s) : 0, 1233880
Total [candidate] (9.336 s) : 0, 9336270

baseline results

Module	Variant	Duration	Δ tracing
Agent	tracing	1.064 s	-
Agent	iast	1.241 s	176.957 ms (16.6%)
Total	tracing	8.746 s	-
Total	iast	9.378 s	632.351 ms (7.2%)

candidate results

Module	Variant	Duration	Δ tracing
Agent	tracing	1.065 s	-
Agent	iast	1.234 s	169.123 ms (15.9%)
Total	tracing	8.748 s	-
Total	iast	9.336 s	588.76 ms (6.7%)

gantt
    title insecure-bank - break down per module: candidate=1.60.0-SNAPSHOT~791045757c, baseline=1.60.0-SNAPSHOT~405276aea3

    dateFormat X
    axisFormat %s
section tracing
crashtracking [baseline] (1.186 ms) : 0, 1186
crashtracking [candidate] (1.186 ms) : 0, 1186
BytebuddyAgent [baseline] (628.51 ms) : 0, 628510
BytebuddyAgent [candidate] (628.487 ms) : 0, 628487
AgentMeter [baseline] (29.036 ms) : 0, 29036
AgentMeter [candidate] (28.843 ms) : 0, 28843
GlobalTracer [baseline] (256.986 ms) : 0, 256986
GlobalTracer [candidate] (257.74 ms) : 0, 257740
AppSec [baseline] (32.611 ms) : 0, 32611
AppSec [candidate] (32.768 ms) : 0, 32768
Debugger [baseline] (59.706 ms) : 0, 59706
Debugger [candidate] (60.61 ms) : 0, 60610
Remote Config [baseline] (641.778 µs) : 0, 642
Remote Config [candidate] (630.85 µs) : 0, 631
Telemetry [baseline] (13.774 ms) : 0, 13774
Telemetry [candidate] (14.564 ms) : 0, 14564
Flare Poller [baseline] (6.106 ms) : 0, 6106
Flare Poller [candidate] (4.641 ms) : 0, 4641
section iast
crashtracking [baseline] (1.183 ms) : 0, 1183
crashtracking [candidate] (1.173 ms) : 0, 1173
BytebuddyAgent [baseline] (803.195 ms) : 0, 803195
BytebuddyAgent [candidate] (797.981 ms) : 0, 797981
AgentMeter [baseline] (11.58 ms) : 0, 11580
AgentMeter [candidate] (11.272 ms) : 0, 11272
GlobalTracer [baseline] (249.337 ms) : 0, 249337
GlobalTracer [candidate] (248.8 ms) : 0, 248800
IAST [baseline] (27.329 ms) : 0, 27329
IAST [candidate] (27.027 ms) : 0, 27027
AppSec [baseline] (35.824 ms) : 0, 35824
AppSec [candidate] (35.04 ms) : 0, 35040
Debugger [baseline] (64.15 ms) : 0, 64150
Debugger [candidate] (64.776 ms) : 0, 64776
Remote Config [baseline] (532.635 µs) : 0, 533
Remote Config [candidate] (536.607 µs) : 0, 537
Telemetry [baseline] (8.716 ms) : 0, 8716
Telemetry [candidate] (8.625 ms) : 0, 8625
Flare Poller [baseline] (3.572 ms) : 0, 3572
Flare Poller [candidate] (3.41 ms) : 0, 3410

Load

Parameters

	Baseline	Candidate
baseline_or_candidate	baseline	candidate
git_branch	master	kr-igor/fix-kafka-extractor
git_commit_date	1771346510	1771365821
git_commit_sha	`405276a`	`7910457`
release_version	1.60.0-SNAPSHOT~405276aea3	1.60.0-SNAPSHOT~791045757c

See matching parameters

	Baseline	Candidate
application	insecure-bank	insecure-bank
ci_job_date	1771368461	1771368461
ci_job_id	1433685196	1433685196
ci_pipeline_id	97073793	97073793
cpu_model	Intel(R) Xeon(R) Platinum 8259CL CPU @ 2.50GHz	Intel(R) Xeon(R) Platinum 8259CL CPU @ 2.50GHz
kernel_version	Linux runner-zfyrx7zua-project-304-concurrent-0-52jybkf7 6.8.0-1031-aws #33~22.04.1-Ubuntu SMP Thu Jun 26 14:22:30 UTC 2025 x86_64 x86_64 x86_64 GNU/Linux	Linux runner-zfyrx7zua-project-304-concurrent-0-52jybkf7 6.8.0-1031-aws #33~22.04.1-Ubuntu SMP Thu Jun 26 14:22:30 UTC 2025 x86_64 x86_64 x86_64 GNU/Linux

Summary

Found 3 performance improvements and 0 performance regressions! Performance is the same for 17 metrics, 16 unstable metrics.

scenario	Δ mean agg_http_req_duration_p50	Δ mean agg_http_req_duration_p95	Δ mean throughput	candidate mean agg_http_req_duration_p50	candidate mean agg_http_req_duration_p95	candidate mean throughput	baseline mean agg_http_req_duration_p50	baseline mean agg_http_req_duration_p95	baseline mean throughput
scenario:load:insecure-bank:iast_GLOBAL:high_load	unsure [-167.555µs; -43.901µs] or [-5.958%; -1.561%]	better [-586.976µs; -215.555µs] or [-7.351%; -2.699%]	unstable [-83.653op/s; +204.216op/s] or [-6.588%; +16.083%]	2.707ms	7.584ms	1330.031op/s	2.812ms	7.985ms	1269.750op/s
scenario:load:insecure-bank:iast:high_load	better [-229.211µs; -154.886µs] or [-9.187%; -6.208%]	better [-747.143µs; -359.439µs] or [-10.021%; -4.821%]	unstable [-34.212op/s; +271.962op/s] or [-2.427%; +19.296%]	2.303ms	6.902ms	1528.312op/s	2.495ms	7.455ms	1409.438op/s

Request duration reports for petclinic

gantt
    title petclinic - request duration [CI 0.99] : candidate=1.60.0-SNAPSHOT~791045757c, baseline=1.60.0-SNAPSHOT~405276aea3
    dateFormat X
    axisFormat %s
section baseline
no_agent (18.357 ms) : 18167, 18546
.   : milestone, 18357,
appsec (19.1 ms) : 18908, 19292
.   : milestone, 19100,
code_origins (17.56 ms) : 17385, 17734
.   : milestone, 17560,
iast (17.654 ms) : 17477, 17832
.   : milestone, 17654,
profiling (18.608 ms) : 18421, 18794
.   : milestone, 18608,
tracing (17.687 ms) : 17512, 17862
.   : milestone, 17687,
section candidate
no_agent (19.208 ms) : 19010, 19405
.   : milestone, 19208,
appsec (18.604 ms) : 18415, 18794
.   : milestone, 18604,
code_origins (17.617 ms) : 17443, 17792
.   : milestone, 17617,
iast (17.571 ms) : 17395, 17748
.   : milestone, 17571,
profiling (18.466 ms) : 18284, 18649
.   : milestone, 18466,
tracing (17.704 ms) : 17528, 17880
.   : milestone, 17704,

baseline results

Variant	Request duration [CI 0.99]	Δ no_agent
no_agent	18.357 ms [18.167 ms, 18.546 ms]	-
appsec	19.1 ms [18.908 ms, 19.292 ms]	743.052 µs (4.0%)
code_origins	17.56 ms [17.385 ms, 17.734 ms]	-796.979 µs (-4.3%)
iast	17.654 ms [17.477 ms, 17.832 ms]	-702.517 µs (-3.8%)
profiling	18.608 ms [18.421 ms, 18.794 ms]	251.122 µs (1.4%)
tracing	17.687 ms [17.512 ms, 17.862 ms]	-669.667 µs (-3.6%)

candidate results

Variant	Request duration [CI 0.99]	Δ no_agent
no_agent	19.208 ms [19.01 ms, 19.405 ms]	-
appsec	18.604 ms [18.415 ms, 18.794 ms]	-603.41 µs (-3.1%)
code_origins	17.617 ms [17.443 ms, 17.792 ms]	-1.59 ms (-8.3%)
iast	17.571 ms [17.395 ms, 17.748 ms]	-1.637 ms (-8.5%)
profiling	18.466 ms [18.284 ms, 18.649 ms]	-741.281 µs (-3.9%)
tracing	17.704 ms [17.528 ms, 17.88 ms]	-1.503 ms (-7.8%)

Request duration reports for insecure-bank

gantt
    title insecure-bank - request duration [CI 0.99] : candidate=1.60.0-SNAPSHOT~791045757c, baseline=1.60.0-SNAPSHOT~405276aea3
    dateFormat X
    axisFormat %s
section baseline
no_agent (1.199 ms) : 1187, 1211
.   : milestone, 1199,
iast (3.248 ms) : 3205, 3291
.   : milestone, 3248,
iast_FULL (5.96 ms) : 5899, 6021
.   : milestone, 5960,
iast_GLOBAL (3.612 ms) : 3551, 3673
.   : milestone, 3612,
profiling (1.969 ms) : 1952, 1986
.   : milestone, 1969,
tracing (1.789 ms) : 1774, 1803
.   : milestone, 1789,
section candidate
no_agent (1.186 ms) : 1174, 1197
.   : milestone, 1186,
iast (2.988 ms) : 2955, 3022
.   : milestone, 2988,
iast_FULL (5.773 ms) : 5715, 5831
.   : milestone, 5773,
iast_GLOBAL (3.446 ms) : 3390, 3502
.   : milestone, 3446,
profiling (2.039 ms) : 2022, 2056
.   : milestone, 2039,
tracing (1.803 ms) : 1788, 1818
.   : milestone, 1803,

baseline results

Variant	Request duration [CI 0.99]	Δ no_agent
no_agent	1.199 ms [1.187 ms, 1.211 ms]	-
iast	3.248 ms [3.205 ms, 3.291 ms]	2.049 ms (170.9%)
iast_FULL	5.96 ms [5.899 ms, 6.021 ms]	4.761 ms (397.2%)
iast_GLOBAL	3.612 ms [3.551 ms, 3.673 ms]	2.413 ms (201.3%)
profiling	1.969 ms [1.952 ms, 1.986 ms]	769.99 µs (64.2%)
tracing	1.789 ms [1.774 ms, 1.803 ms]	589.83 µs (49.2%)

candidate results

Variant	Request duration [CI 0.99]	Δ no_agent
no_agent	1.186 ms [1.174 ms, 1.197 ms]	-
iast	2.988 ms [2.955 ms, 3.022 ms]	1.803 ms (152.0%)
iast_FULL	5.773 ms [5.715 ms, 5.831 ms]	4.587 ms (386.9%)
iast_GLOBAL	3.446 ms [3.39 ms, 3.502 ms]	2.26 ms (190.6%)
profiling	2.039 ms [2.022 ms, 2.056 ms]	853.47 µs (72.0%)
tracing	1.803 ms [1.788 ms, 1.818 ms]	617.475 µs (52.1%)

Dacapo

Parameters

	Baseline	Candidate
baseline_or_candidate	baseline	candidate
git_branch	master	kr-igor/fix-kafka-extractor
git_commit_date	1771346510	1771365821
git_commit_sha	`405276a`	`7910457`
release_version	1.60.0-SNAPSHOT~405276aea3	1.60.0-SNAPSHOT~791045757c

See matching parameters

	Baseline	Candidate
application	biojava	biojava
ci_job_date	1771368178	1771368178
ci_job_id	1433685197	1433685197
ci_pipeline_id	97073793	97073793
cpu_model	Intel(R) Xeon(R) Platinum 8259CL CPU @ 2.50GHz	Intel(R) Xeon(R) Platinum 8259CL CPU @ 2.50GHz
kernel_version	Linux runner-zfyrx7zua-project-304-concurrent-0-k2pfakx1 6.8.0-1031-aws #33~22.04.1-Ubuntu SMP Thu Jun 26 14:22:30 UTC 2025 x86_64 x86_64 x86_64 GNU/Linux	Linux runner-zfyrx7zua-project-304-concurrent-0-k2pfakx1 6.8.0-1031-aws #33~22.04.1-Ubuntu SMP Thu Jun 26 14:22:30 UTC 2025 x86_64 x86_64 x86_64 GNU/Linux

Summary

Found 0 performance improvements and 0 performance regressions! Performance is the same for 10 metrics, 2 unstable metrics.

Execution time for tomcat

gantt
    title tomcat - execution time [CI 0.99] : candidate=1.60.0-SNAPSHOT~791045757c, baseline=1.60.0-SNAPSHOT~405276aea3
    dateFormat X
    axisFormat %s
section baseline
no_agent (1.48 ms) : 1468, 1491
.   : milestone, 1480,
appsec (3.796 ms) : 3577, 4014
.   : milestone, 3796,
iast (2.265 ms) : 2195, 2334
.   : milestone, 2265,
iast_GLOBAL (2.315 ms) : 2245, 2384
.   : milestone, 2315,
profiling (2.114 ms) : 2056, 2171
.   : milestone, 2114,
tracing (2.077 ms) : 2024, 2131
.   : milestone, 2077,
section candidate
no_agent (1.479 ms) : 1467, 1490
.   : milestone, 1479,
appsec (3.8 ms) : 3577, 4023
.   : milestone, 3800,
iast (2.268 ms) : 2198, 2338
.   : milestone, 2268,
iast_GLOBAL (2.306 ms) : 2237, 2376
.   : milestone, 2306,
profiling (2.516 ms) : 2352, 2680
.   : milestone, 2516,
tracing (2.077 ms) : 2023, 2131
.   : milestone, 2077,

baseline results

Variant	Execution Time [CI 0.99]	Δ no_agent
no_agent	1.48 ms [1.468 ms, 1.491 ms]	-
appsec	3.796 ms [3.577 ms, 4.014 ms]	2.316 ms (156.5%)
iast	2.265 ms [2.195 ms, 2.334 ms]	785.231 µs (53.1%)
iast_GLOBAL	2.315 ms [2.245 ms, 2.384 ms]	835.344 µs (56.5%)
profiling	2.114 ms [2.056 ms, 2.171 ms]	634.357 µs (42.9%)
tracing	2.077 ms [2.024 ms, 2.131 ms]	597.699 µs (40.4%)

candidate results

Variant	Execution Time [CI 0.99]	Δ no_agent
no_agent	1.479 ms [1.467 ms, 1.49 ms]	-
appsec	3.8 ms [3.577 ms, 4.023 ms]	2.321 ms (157.0%)
iast	2.268 ms [2.198 ms, 2.338 ms]	789.526 µs (53.4%)
iast_GLOBAL	2.306 ms [2.237 ms, 2.376 ms]	827.677 µs (56.0%)
profiling	2.516 ms [2.352 ms, 2.68 ms]	1.038 ms (70.2%)
tracing	2.077 ms [2.023 ms, 2.131 ms]	597.936 µs (40.4%)

Execution time for biojava

gantt
    title biojava - execution time [CI 0.99] : candidate=1.60.0-SNAPSHOT~791045757c, baseline=1.60.0-SNAPSHOT~405276aea3
    dateFormat X
    axisFormat %s
section baseline
no_agent (15.556 s) : 15556000, 15556000
.   : milestone, 15556000,
appsec (14.826 s) : 14826000, 14826000
.   : milestone, 14826000,
iast (18.075 s) : 18075000, 18075000
.   : milestone, 18075000,
iast_GLOBAL (17.899 s) : 17899000, 17899000
.   : milestone, 17899000,
profiling (14.868 s) : 14868000, 14868000
.   : milestone, 14868000,
tracing (14.827 s) : 14827000, 14827000
.   : milestone, 14827000,
section candidate
no_agent (14.928 s) : 14928000, 14928000
.   : milestone, 14928000,
appsec (14.94 s) : 14940000, 14940000
.   : milestone, 14940000,
iast (17.966 s) : 17966000, 17966000
.   : milestone, 17966000,
iast_GLOBAL (17.8 s) : 17800000, 17800000
.   : milestone, 17800000,
profiling (14.763 s) : 14763000, 14763000
.   : milestone, 14763000,
tracing (14.959 s) : 14959000, 14959000
.   : milestone, 14959000,

baseline results

Variant	Execution Time [CI 0.99]	Δ no_agent
no_agent	15.556 s [15.556 s, 15.556 s]	-
appsec	14.826 s [14.826 s, 14.826 s]	-730.0 ms (-4.7%)
iast	18.075 s [18.075 s, 18.075 s]	2.519 s (16.2%)
iast_GLOBAL	17.899 s [17.899 s, 17.899 s]	2.343 s (15.1%)
profiling	14.868 s [14.868 s, 14.868 s]	-688.0 ms (-4.4%)
tracing	14.827 s [14.827 s, 14.827 s]	-729.0 ms (-4.7%)

candidate results

Variant	Execution Time [CI 0.99]	Δ no_agent
no_agent	14.928 s [14.928 s, 14.928 s]	-
appsec	14.94 s [14.94 s, 14.94 s]	12.0 ms (0.1%)
iast	17.966 s [17.966 s, 17.966 s]	3.038 s (20.4%)
iast_GLOBAL	17.8 s [17.8 s, 17.8 s]	2.872 s (19.2%)
profiling	14.763 s [14.763 s, 14.763 s]	-165.0 ms (-1.1%)
tracing	14.959 s [14.959 s, 14.959 s]	31.0 ms (0.2%)

pr-commenter · 2026-02-17T18:31:58Z

Kafka / consumer-benchmark

Parameters

	Baseline	Candidate
baseline_or_candidate	baseline	candidate
git_branch	master	kr-igor/fix-kafka-extractor
git_commit_date	1771346510	1771354754
git_commit_sha	`405276a`	`b823f07`

See matching parameters

	Baseline	Candidate
ci_job_date	1771355797	1771355797
ci_job_id	1432969930	1432969930
ci_pipeline_id	97008544	97008544
cpu_model	Intel(R) Xeon(R) Platinum 8259CL CPU @ 2.50GHz	Intel(R) Xeon(R) Platinum 8259CL CPU @ 2.50GHz
jdkVersion	11.0.25	11.0.25
jmhVersion	1.36	1.36
jvm	/usr/lib/jvm/java-11-openjdk-amd64/bin/java	/usr/lib/jvm/java-11-openjdk-amd64/bin/java
jvmArgs	-Dfile.encoding=UTF-8 -Djava.io.tmpdir=/go/src/github.com/DataDog/apm-reliability/dd-trace-java/platform/src/consumer-benchmark/build/tmp/jmh -Duser.country=US -Duser.language=en -Duser.variant	-Dfile.encoding=UTF-8 -Djava.io.tmpdir=/go/src/github.com/DataDog/apm-reliability/dd-trace-java/platform/src/consumer-benchmark/build/tmp/jmh -Duser.country=US -Duser.language=en -Duser.variant
vmName	OpenJDK 64-Bit Server VM	OpenJDK 64-Bit Server VM
vmVersion	11.0.25+9-post-Ubuntu-1ubuntu122.04	11.0.25+9-post-Ubuntu-1ubuntu122.04

Summary

Found 0 performance improvements and 0 performance regressions! Performance is the same for 3 metrics, 0 unstable metrics.

See unchanged results

scenario	Δ mean throughput
scenario:not-instrumented/KafkaConsumerBenchmark.benchConsume	same
scenario:only-tracing-dsm-disabled-benchmarks/KafkaConsumerBenchmark.benchConsume	same
scenario:only-tracing-dsm-enabled-benchmarks/KafkaConsumerBenchmark.benchConsume	same

amarziali · 2026-02-17T20:41:30Z

.../src/main/java/datadog/trace/instrumentation/kafka_clients/KafkaProducerInstrumentation.java

              span,
              DataStreamsTransactionExtractor.Type.KAFKA_PRODUCE_HEADERS,
-              record,
+              record.headers(),


ok but I would protect rather this:

DSM_TRANSACTION_SOURCE_READER = (source, headerName) -> new String(((Headers) source).lastHeader(headerName).value());

or better type the argument to prevent in the future this kind of issues

added protective try/catch for all header readers to keep it simple for now.

amarziali

thanks for the fix

amarziali · 2026-02-17T21:56:05Z

...rap/src/main/java/datadog/trace/bootstrap/instrumentation/decorator/HttpClientDecorator.java

+          (source, headerName) -> {
+            try {
+              return getRequestHeader((REQUEST) source, headerName);
+            } catch (Exception e) {


Suggested change

} catch (Exception e) {

} catch (Throwable ignored) {

Fixed kafka produce extractor

b304ba5

kr-igor requested review from a team as code owners February 17, 2026 17:43

Fixed DSM test

b823f07

kr-igor changed the title ~~[DSM] - Fixed kafka produce extractor~~ Fixed kafka produce extractor error Feb 17, 2026

kr-igor added comp: data streams Data Streams Monitoring type: bug Bug report and fix labels Feb 17, 2026

amarziali reviewed Feb 17, 2026

View reviewed changes

ericfirth approved these changes Feb 17, 2026

View reviewed changes

Added try/except for source readers

74e942c

amarziali approved these changes Feb 17, 2026

View reviewed changes

amarziali reviewed Feb 17, 2026

View reviewed changes

Use Throwable

7910457

kr-igor merged commit 16f3647 into master Feb 17, 2026
548 checks passed

kr-igor deleted the kr-igor/fix-kafka-extractor branch February 17, 2026 23:52

github-actions bot added this to the 1.60.0 milestone Feb 17, 2026

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Fixed kafka produce extractor error#10610

Fixed kafka produce extractor error#10610
kr-igor merged 4 commits intomasterfrom
kr-igor/fix-kafka-extractor

kr-igor commented Feb 17, 2026

Uh oh!

github-actions bot commented Feb 17, 2026 •

edited

Loading

Uh oh!

pr-commenter bot commented Feb 17, 2026 •

edited

Loading

Uh oh!

pr-commenter bot commented Feb 17, 2026 •

edited

Loading

Uh oh!

pr-commenter bot commented Feb 17, 2026 •

edited

Loading

Uh oh!

amarziali Feb 17, 2026

Uh oh!

kr-igor Feb 17, 2026

Uh oh!

amarziali left a comment

Uh oh!

amarziali Feb 17, 2026

Uh oh!

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

Conversation

kr-igor commented Feb 17, 2026

What Does This Do

Motivation

Uh oh!

github-actions bot commented Feb 17, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

pr-commenter bot commented Feb 17, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Kafka / producer-benchmark

Parameters

Summary

Uh oh!

pr-commenter bot commented Feb 17, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Benchmarks

Startup

Parameters

Summary

Load

Parameters

Summary

Dacapo

Parameters

Summary

Uh oh!

pr-commenter bot commented Feb 17, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Kafka / consumer-benchmark

Parameters

Summary

Uh oh!

amarziali Feb 17, 2026

Choose a reason for hiding this comment

Uh oh!

kr-igor Feb 17, 2026

Choose a reason for hiding this comment

Uh oh!

amarziali left a comment

Choose a reason for hiding this comment

Uh oh!

amarziali Feb 17, 2026

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

github-actions bot commented Feb 17, 2026 •

edited

Loading

pr-commenter bot commented Feb 17, 2026 •

edited

Loading

pr-commenter bot commented Feb 17, 2026 •

edited

Loading

pr-commenter bot commented Feb 17, 2026 •

edited

Loading