🍒 12007 - Fix NoSuchElementException from unchecked Optional.get() in Kafka consumer instrumentation

[PerfectSlayer]

Backport #12007 to release/v1.64.x

[datadog-prod-us1-5]

More details

The helper now safely maps absent consumer-group, metadata, and bootstrap-server optionals to null while preserving present values, and the callback path already uses the same safe behavior. No diff-only behavioral regression was identified; local execution was blocked before compilation by the unavailable Java 25 toolchain.

Was this helpful? React 👍 or 👎

_{Open Bits AI session}

_{🤖 Datadog Autotest · Commit 220be5d · What is Autotest? · @DataDog review to ask questions · Any feedback? Reach out in #autotest}

[datadog-prod-us1-5]

🎯 Code Coverage (details)
• Patch Coverage: 100.00%
• Overall Coverage: 69.73% (+12.79%)

_{This comment will be updated automatically if new data arrives.
🔗 Commit SHA: 220be5d | Docs | Datadog PR Page | Give us feedback!}

[dd-octo-sts]

🟢 Java Benchmark SLOs — All performance SLOs passed

Suite	Status
Startup	🟢 pass

SLO thresholds are defined here based on automatically generated metrics. A warning is raised when results are within 5% of the threshold.

PR vs. master results

Scenario	Candidate	master	Δ (95% CI of mean)
startup:insecure-bank:iast:Agent	13.92 s	13.98 s	[-1.2%; +0.4%] (no difference)
startup:insecure-bank:tracing:Agent	12.87 s	13.00 s	[-1.7%; -0.3%] (maybe better)
startup:petclinic:appsec:Agent	16.81 s	16.78 s	[-0.9%; +1.2%] (no difference)
startup:petclinic:iast:Agent	16.91 s	16.94 s	[-0.9%; +0.6%] (no difference)
startup:petclinic:profiling:Agent	16.19 s	16.89 s	[-8.3%; +0.1%] (no difference)
startup:petclinic:sca:Agent	16.91 s	16.72 s	[+0.1%; +2.1%] (maybe worse)
startup:petclinic:tracing:Agent	15.67 s	16.10 s	[-6.9%; +1.6%] (no difference)

Commit: 220be5dc · CI Pipeline · Benchmarking Platform UI

---

Load and DaCapo benchmarks can be triggered manually in the GitLab pipeline. Results will appear in the Benchmarking Platform UI after completion.

[pr-commenter]

Kafka / producer-benchmark

Parameters

	Baseline	Candidate
baseline_or_candidate	baseline	candidate
git_branch	release/v1.64.x	bruce.bujon/backport-pr-12007
git_commit_date	1784129122	1784898858
git_commit_sha	5b36a52	220be5d

See matching parameters

	Baseline	Candidate
ci_job_date	1784899897	1784899897
ci_job_id	1890977779	1890977779
ci_pipeline_id	126780277	126780277
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]

Kafka / consumer-benchmark

Parameters

	Baseline	Candidate
baseline_or_candidate	baseline	candidate
git_branch	release/v1.64.x	bruce.bujon/backport-pr-12007
git_commit_date	1784129122	1784898858
git_commit_sha	5b36a52	220be5d

See matching parameters

	Baseline	Candidate
ci_job_date	1784899938	1784899938
ci_job_id	1890977781	1890977781
ci_pipeline_id	126780277	126780277
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	unsure [-19926.623op/s; -1452.894op/s] or [-6.396%; -0.466%]
scenario:only-tracing-dsm-enabled-benchmarks/KafkaConsumerBenchmark.benchConsume	same