feat(aiokafka): add aiokafka integration with APM and DSM support#14975

Open

dubloom wants to merge 41 commits intomainfrom

dubloom/aiokafka

Commits on Oct 20, 2025

fix(kafka): only the first message was dispatch to dsm
dubloom
committed
feat: add aiokafka skeleton

ls-pieter-vanisacker
authored and
dubloom
committed
fix: tweak skeleton

ls-pieter-vanisacker
authored and
dubloom
committed
feat: add wrapping logic and tests

ls-pieter-vanisacker
authored and
dubloom
committed
tests: fix suitespec and async wrappers

ls-pieter-vanisacker
authored and
dubloom
committed
tests: make auto patch test work

ls-pieter-vanisacker
authored and
dubloom
committed
fix: add riot requirements for python 3.12

ls-pieter-vanisacker
authored and
dubloom
committed
fix: requirements for python 3.8

ls-pieter-vanisacker
authored and
dubloom
committed
tests: add first batch of tests

ls-pieter-vanisacker
authored and
dubloom
committed
feat: implement getone and getmany tracing

ls-pieter-vanisacker
authored and
dubloom
committed
fix: add needed requirements files, put some sleep for other getmany tests

ls-pieter-vanisacker
authored and
dubloom
committed
fix: clean up requirements files

ls-pieter-vanisacker
authored and
dubloom
committed
fix: add more tests and make sure they pass

ls-pieter-vanisacker
authored and
dubloom
committed
fix: ensure distributed tracing actually works

ls-pieter-vanisacker
authored and
dubloom
committed
fix: add basic support for DSM

ls-pieter-vanisacker
authored and
dubloom
committed
fix: DSM offset handling function

ls-pieter-vanisacker
authored and
dubloom
committed
fix: make offset capturing work in DSM for send_and_wait

ls-pieter-vanisacker
authored and
dubloom
committed
Update ddtrace/contrib/aiokafka/patch.py

authored and
dubloom
committed
refactor: wrapping logic

ls-pieter-vanisacker
authored and
dubloom
committed
fix: rework the code, only deal with send_and_wait and getone for now

ls-pieter-vanisacker
authored and
dubloom
committed
Update ddtrace/contrib/aiokafka/patch.py

authored and
dubloom
committed
Update ddtrace/contrib/aiokafka/patch.py

authored and
dubloom
committed
Update ddtrace/contrib/aiokafka/patch.py

authored and
dubloom
committed
Update ddtrace/_trace/trace_handlers.py

authored and
dubloom
committed
fix: make basic tests run again after feedback

ls-pieter-vanisacker
authored and
dubloom
committed
tests: make some of the patch tests work already

ls-pieter-vanisacker
authored and
dubloom
committed
fix: patching tests for real?

ls-pieter-vanisacker
authored and
dubloom
committed
fix: move logic to trace_handlers

ls-pieter-vanisacker
authored and
dubloom
committed
fix: first iteration of distributed tracing

ls-pieter-vanisacker
authored and
dubloom
committed
fix: make distributed tracing work

ls-pieter-vanisacker
authored and
dubloom
committed
fix: make data streams monitoring work

ls-pieter-vanisacker
authored and
dubloom
committed
fix: instrument producer.send and consumer.getmany

ls-pieter-vanisacker
authored and
dubloom
committed
fix: update doc

ls-pieter-vanisacker
authored and
dubloom
committed
fix: format snapshots

ls-pieter-vanisacker
authored and
dubloom
committed
reno

emmettbutler
authored and
dubloom
committed
feat(aiokafka): finish integration with APM & DSM
dubloom
committed