Decouple Kafka DSM instrumentation from APM tracing enablement - #12350

Draft

ericfirth wants to merge 24 commits into

worktree-dsm-kafka-decoupling

Commits on Aug 26, 2026

Add InstrumenterConfig.isDataStreamsEnabled() accessor

ericfirth
and
claude
committed
14f3422

Commits on Aug 28, 2026

Add TargetSystem.DATA_STREAMS and InstrumenterModule.DataStreams base class
ericfirth
committed
bc5b126
Add isEnabled() test coverage for DataStreams
ericfirth
committed
ab45b03
Fix test isolation bug in testDataStreamsIsEnabledWhenDataStreamsEnabledOverridesFalse
ericfirth
committed
d93cdd3
Remove unused AfterEach import from InstrumenterModuleTest

ericfirth
and
claude
committed
4b971cf
Wire AgentInstaller.getEnabledSystems() to DATA_STREAMS target system

ericfirth
and
claude
committed
e06d87a
Add SamplingMechanism.DATA_STREAMS constant

ericfirth
and
claude
committed
88d3ced
Fix DATA_STREAMS case formatting to match DATA_JOBS style

ericfirth
and
claude
committed
d415510
Swap kafka-clients-0.11 instrumentations to InstrumenterModule.DataStreams base class

ericfirth
and
claude
committed
1f63ee4
Suppress APM billing for DSM-only Kafka produce spans

ericfirth
and
claude
committed
9d6e647
Swap kafka-clients-3.8 instrumentations to InstrumenterModule.DataStreams base class

ericfirth
and
claude
committed
0d7f5f8
Decouple DSM from APM tracing in kafka-clients-3.8 (produce and consume paths)

ericfirth
and
claude
committed
9c85a52
chore: kafka-streams-0.11 DSM decoupling (base-class swap + suppression)
ericfirth
committed
d4c4904
refactor: change kafka-streams-1.0 InternalTopologyBuilderInstrumentation to DataStreams

ericfirth
and
claude
committed
4c77872
refactor: decouple kafka-connect-0.11 instrumentation from APM tracing

ericfirth
and
claude
committed
4a3bcfb
Migrate InstrumenterConfigTest to JUnit 5 and add isDataStreamsEnabled tests

ericfirth
and
claude
committed
8b7aebf
Migrate SamplingMechanismTest to JUnit 5 and add DATA_STREAMS cases

ericfirth
and
claude
committed
25935aa
test: add JUnit 5 tests for AgentInstaller.getEnabledSystems() DATA_STREAMS flag

ericfirth
and
claude
committed
f755f81
fix: suppress APM billing for DSM-only Kafka consume spans in kafka-clients-0.11
ericfirth
committed
3e47f9e
Add tests for DSM billing suppression on kafka produce/consume spans

ericfirth
and
claude
committed
86764eb
fix: only force DSM-only USER_DROP when the Kafka span owns the local trace

ericfirth
and
claude
committed
dcce923
fix: keep Kafka Code Origin instrumentation on the Tracing base class

ericfirth
and
claude
committed
3bad75e
test: cover DSM-only sampling suppression for Kafka produce, consume and streams

ericfirth
and
claude
committed
dd07f44

Commits on Aug 31, 2026

fix: suppress DSM-only Kafka poll-span billing gap and address code review findings

ericfirth
and
claude
committed
8f5f263