Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
41 commits
Select commit Hold shift + click to select a range
436d673
fix(kafka): only the first message was dispatch to dsm
dubloom Oct 20, 2025
0bfe146
feat: add aiokafka skeleton
ls-pieter-vanisacker Jul 29, 2024
7ea77c6
fix: tweak skeleton
ls-pieter-vanisacker Aug 4, 2024
5d92c8c
feat: add wrapping logic and tests
ls-pieter-vanisacker Aug 4, 2024
e514fa4
tests: fix suitespec and async wrappers
ls-pieter-vanisacker Aug 4, 2024
0f9baea
tests: make auto patch test work
ls-pieter-vanisacker Aug 4, 2024
15231de
fix: add riot requirements for python 3.12
ls-pieter-vanisacker Aug 5, 2024
a338b3d
fix: requirements for python 3.8
ls-pieter-vanisacker Aug 5, 2024
45df669
tests: add first batch of tests
ls-pieter-vanisacker Aug 6, 2024
4a88cb7
feat: implement getone and getmany tracing
ls-pieter-vanisacker Aug 7, 2024
42c9f82
fix: add needed requirements files, put some sleep for other getmany …
ls-pieter-vanisacker Aug 7, 2024
fef7fbc
fix: clean up requirements files
ls-pieter-vanisacker Aug 7, 2024
5e1785b
fix: add more tests and make sure they pass
ls-pieter-vanisacker Aug 7, 2024
859405d
fix: ensure distributed tracing actually works
ls-pieter-vanisacker Aug 7, 2024
d5fd99e
fix: add basic support for DSM
ls-pieter-vanisacker Aug 8, 2024
ababf55
fix: DSM offset handling function
ls-pieter-vanisacker Aug 8, 2024
c8aa159
fix: make offset capturing work in DSM for send_and_wait
ls-pieter-vanisacker Aug 8, 2024
4f824f3
Update ddtrace/contrib/aiokafka/patch.py
ls-pieter-vanisacker Aug 9, 2024
132025b
refactor: wrapping logic
ls-pieter-vanisacker Aug 9, 2024
7093210
fix: rework the code, only deal with send_and_wait and getone for now
ls-pieter-vanisacker Aug 20, 2024
349820f
Update ddtrace/contrib/aiokafka/patch.py
ls-pieter-vanisacker Aug 24, 2024
f295b81
Update ddtrace/contrib/aiokafka/patch.py
ls-pieter-vanisacker Aug 24, 2024
7f3fd9d
Update ddtrace/contrib/aiokafka/patch.py
ls-pieter-vanisacker Aug 24, 2024
e2e04f0
Update ddtrace/_trace/trace_handlers.py
ls-pieter-vanisacker Aug 24, 2024
b129416
fix: make basic tests run again after feedback
ls-pieter-vanisacker Aug 24, 2024
3ccb963
tests: make some of the patch tests work already
ls-pieter-vanisacker Aug 24, 2024
05e73dc
fix: patching tests for real?
ls-pieter-vanisacker Aug 24, 2024
02d2667
fix: move logic to trace_handlers
ls-pieter-vanisacker Aug 24, 2024
d9057d0
fix: first iteration of distributed tracing
ls-pieter-vanisacker Aug 24, 2024
dcf9a4e
fix: make distributed tracing work
ls-pieter-vanisacker Aug 29, 2024
79b3d27
fix: make data streams monitoring work
ls-pieter-vanisacker Aug 29, 2024
186ebcf
fix: instrument producer.send and consumer.getmany
ls-pieter-vanisacker Sep 2, 2024
84a0e82
fix: update doc
ls-pieter-vanisacker Sep 2, 2024
2b4aeab
fix: format snapshots
ls-pieter-vanisacker Sep 3, 2024
34df96e
reno
emmettbutler Sep 4, 2024
38a4556
feat(aiokafka): finish integration with APM & DSM
dubloom Oct 15, 2025
e500fb9
tests(aiokafka): add apm tests
dubloom Oct 20, 2025
02520d4
chore: small improvements
dubloom Oct 21, 2025
8382f1c
add final tests & prepare PR
dubloom Oct 21, 2025
34d5a77
Merge branch 'main' into dubloom/aiokafka
dubloom Oct 21, 2025
832a298
fix: build_docs
dubloom Oct 21, 2025
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
23 changes: 23 additions & 0 deletions .riot/requirements/13e0d21.txt
Original file line number Diff line number Diff line change
@@ -0,0 +1,23 @@
#
# This file is autogenerated by pip-compile with Python 3.13
# by the following command:
#
# pip-compile --allow-unsafe --no-annotate .riot/requirements/13e0d21.in
#
aiokafka==0.9.0
async-timeout==5.0.1
attrs==25.4.0
coverage[toml]==7.11.0
hypothesis==6.45.0
iniconfig==2.3.0
mock==5.2.0
opentracing==2.4.0
packaging==25.0
pluggy==1.6.0
pygments==2.19.2
pytest==8.4.2
pytest-asyncio==1.2.0
pytest-cov==7.0.0
pytest-mock==3.15.1
pytest-randomly==4.0.1
sortedcontainers==2.4.0
24 changes: 24 additions & 0 deletions .riot/requirements/1c72bfb.txt
Original file line number Diff line number Diff line change
@@ -0,0 +1,24 @@
#
# This file is autogenerated by pip-compile with Python 3.13
# by the following command:
#
# pip-compile --allow-unsafe --no-annotate .riot/requirements/1c72bfb.in
#
aiokafka==0.12.0
async-timeout==5.0.1
attrs==25.4.0
coverage[toml]==7.11.0
hypothesis==6.45.0
iniconfig==2.3.0
mock==5.2.0
opentracing==2.4.0
packaging==25.0
pluggy==1.6.0
pygments==2.19.2
pytest==8.4.2
pytest-asyncio==1.2.0
pytest-cov==7.0.0
pytest-mock==3.15.1
pytest-randomly==4.0.1
sortedcontainers==2.4.0
typing-extensions==4.15.0
23 changes: 23 additions & 0 deletions .riot/requirements/1ded764.txt
Original file line number Diff line number Diff line change
@@ -0,0 +1,23 @@
#
# This file is autogenerated by pip-compile with Python 3.14
# by the following command:
#
# pip-compile --allow-unsafe --no-annotate .riot/requirements/1ded764.in
#
aiokafka==0.9.0
async-timeout==5.0.1
attrs==25.4.0
coverage[toml]==7.11.0
hypothesis==6.45.0
iniconfig==2.3.0
mock==5.2.0
opentracing==2.4.0
packaging==25.0
pluggy==1.6.0
pygments==2.19.2
pytest==8.4.2
pytest-asyncio==1.2.0
pytest-cov==7.0.0
pytest-mock==3.15.1
pytest-randomly==4.0.1
sortedcontainers==2.4.0
27 changes: 27 additions & 0 deletions .riot/requirements/2c5336f.txt
Original file line number Diff line number Diff line change
@@ -0,0 +1,27 @@
#
# This file is autogenerated by pip-compile with Python 3.8
# by the following command:
#
# pip-compile --allow-unsafe --no-annotate .riot/requirements/2c5336f.in
#
aiokafka==0.11.0
async-timeout==4.0.3
attrs==24.2.0
coverage[toml]==7.6.1
exceptiongroup==1.2.2
hypothesis==6.45.0
importlib-metadata==8.2.0
iniconfig==2.0.0
mock==5.1.0
opentracing==2.4.0
packaging==24.1
pluggy==1.5.0
pytest==8.3.2
pytest-asyncio==0.23.8
pytest-cov==5.0.0
pytest-mock==3.14.0
pytest-randomly==3.15.0
sortedcontainers==2.4.0
tomli==2.0.1
typing-extensions==4.12.2
zipp==3.19.2
24 changes: 24 additions & 0 deletions .riot/requirements/329b0ed.txt
Original file line number Diff line number Diff line change
@@ -0,0 +1,24 @@
#
# This file is autogenerated by pip-compile with Python 3.12
# by the following command:
#
# pip-compile --allow-unsafe --no-annotate .riot/requirements/329b0ed.in
#
aiokafka==0.9.0
async-timeout==5.0.1
attrs==25.4.0
coverage[toml]==7.11.0
hypothesis==6.45.0
iniconfig==2.3.0
mock==5.2.0
opentracing==2.4.0
packaging==25.0
pluggy==1.6.0
pygments==2.19.2
pytest==8.4.2
pytest-asyncio==1.2.0
pytest-cov==7.0.0
pytest-mock==3.15.1
pytest-randomly==4.0.1
sortedcontainers==2.4.0
typing-extensions==4.15.0
23 changes: 23 additions & 0 deletions .riot/requirements/4532043.txt
Original file line number Diff line number Diff line change
@@ -0,0 +1,23 @@
#
# This file is autogenerated by pip-compile with Python 3.11
# by the following command:
#
# pip-compile --allow-unsafe --no-annotate .riot/requirements/4532043.in
#
aiokafka==0.11.0
async-timeout==4.0.3
attrs==24.2.0
coverage[toml]==7.6.1
hypothesis==6.45.0
iniconfig==2.0.0
mock==5.1.0
opentracing==2.4.0
packaging==24.1
pluggy==1.5.0
pytest==8.3.2
pytest-asyncio==0.23.8
pytest-cov==5.0.0
pytest-mock==3.14.0
pytest-randomly==3.15.0
sortedcontainers==2.4.0
typing-extensions==4.12.2
29 changes: 29 additions & 0 deletions .riot/requirements/538f024.txt
Original file line number Diff line number Diff line change
@@ -0,0 +1,29 @@
#
# This file is autogenerated by pip-compile with Python 3.9
# by the following command:
#
# pip-compile --allow-unsafe --no-annotate .riot/requirements/538f024.in
#
aiokafka==0.9.0
async-timeout==5.0.1
attrs==25.4.0
backports-asyncio-runner==1.2.0
coverage[toml]==7.10.7
exceptiongroup==1.3.0
hypothesis==6.45.0
importlib-metadata==8.7.0
iniconfig==2.1.0
mock==5.2.0
opentracing==2.4.0
packaging==25.0
pluggy==1.6.0
pygments==2.19.2
pytest==8.4.2
pytest-asyncio==1.2.0
pytest-cov==7.0.0
pytest-mock==3.15.1
pytest-randomly==4.0.1
sortedcontainers==2.4.0
tomli==2.3.0
typing-extensions==4.15.0
zipp==3.23.0
27 changes: 27 additions & 0 deletions .riot/requirements/65c09d3.txt
Original file line number Diff line number Diff line change
@@ -0,0 +1,27 @@
#
# This file is autogenerated by pip-compile with Python 3.9
# by the following command:
#
# pip-compile --allow-unsafe --no-annotate .riot/requirements/65c09d3.in
#
aiokafka==0.11.0
async-timeout==4.0.3
attrs==24.2.0
coverage[toml]==7.6.1
exceptiongroup==1.2.2
hypothesis==6.45.0
importlib-metadata==8.2.0
iniconfig==2.0.0
mock==5.1.0
opentracing==2.4.0
packaging==24.1
pluggy==1.5.0
pytest==8.3.2
pytest-asyncio==0.23.8
pytest-cov==5.0.0
pytest-mock==3.14.0
pytest-randomly==3.15.0
sortedcontainers==2.4.0
tomli==2.0.1
typing-extensions==4.12.2
zipp==3.19.2
27 changes: 27 additions & 0 deletions .riot/requirements/a0d2343.txt
Original file line number Diff line number Diff line change
@@ -0,0 +1,27 @@
#
# This file is autogenerated by pip-compile with Python 3.8
# by the following command:
#
# pip-compile --allow-unsafe --no-annotate .riot/requirements/a0d2343.in
#
aiokafka==0.9.0
async-timeout==5.0.1
attrs==25.3.0
coverage[toml]==7.6.1
exceptiongroup==1.3.0
hypothesis==6.45.0
importlib-metadata==8.5.0
iniconfig==2.1.0
mock==5.2.0
opentracing==2.4.0
packaging==25.0
pluggy==1.5.0
pytest==8.3.5
pytest-asyncio==0.24.0
pytest-cov==5.0.0
pytest-mock==3.14.1
pytest-randomly==3.15.0
sortedcontainers==2.4.0
tomli==2.3.0
typing-extensions==4.13.2
zipp==3.20.2
27 changes: 27 additions & 0 deletions .riot/requirements/c6f2827.txt
Original file line number Diff line number Diff line change
@@ -0,0 +1,27 @@
#
# This file is autogenerated by pip-compile with Python 3.10
# by the following command:
#
# pip-compile --allow-unsafe --no-annotate .riot/requirements/c6f2827.in
#
aiokafka==0.9.0
async-timeout==5.0.1
attrs==25.4.0
backports-asyncio-runner==1.2.0
coverage[toml]==7.11.0
exceptiongroup==1.3.0
hypothesis==6.45.0
iniconfig==2.3.0
mock==5.2.0
opentracing==2.4.0
packaging==25.0
pluggy==1.6.0
pygments==2.19.2
pytest==8.4.2
pytest-asyncio==1.2.0
pytest-cov==7.0.0
pytest-mock==3.15.1
pytest-randomly==4.0.1
sortedcontainers==2.4.0
tomli==2.3.0
typing-extensions==4.15.0
23 changes: 23 additions & 0 deletions .riot/requirements/e580d94.txt
Original file line number Diff line number Diff line change
@@ -0,0 +1,23 @@
#
# This file is autogenerated by pip-compile with Python 3.12
# by the following command:
#
# pip-compile --allow-unsafe --no-annotate .riot/requirements/e580d94.in
#
aiokafka==0.11.0
async-timeout==4.0.3
attrs==24.2.0
coverage[toml]==7.6.1
hypothesis==6.45.0
iniconfig==2.0.0
mock==5.1.0
opentracing==2.4.0
packaging==24.1
pluggy==1.5.0
pytest==8.3.2
pytest-asyncio==0.23.8
pytest-cov==5.0.0
pytest-mock==3.14.0
pytest-randomly==3.15.0
sortedcontainers==2.4.0
typing-extensions==4.12.2
24 changes: 24 additions & 0 deletions .riot/requirements/fbd9c5b.txt
Original file line number Diff line number Diff line change
@@ -0,0 +1,24 @@
#
# This file is autogenerated by pip-compile with Python 3.11
# by the following command:
#
# pip-compile --allow-unsafe --no-annotate .riot/requirements/fbd9c5b.in
#
aiokafka==0.9.0
async-timeout==5.0.1
attrs==25.4.0
coverage[toml]==7.11.0
hypothesis==6.45.0
iniconfig==2.3.0
mock==5.2.0
opentracing==2.4.0
packaging==25.0
pluggy==1.6.0
pygments==2.19.2
pytest==8.4.2
pytest-asyncio==1.2.0
pytest-cov==7.0.0
pytest-mock==3.15.1
pytest-randomly==4.0.1
sortedcontainers==2.4.0
typing-extensions==4.15.0
25 changes: 25 additions & 0 deletions .riot/requirements/fbe6b3d.txt
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
#
# This file is autogenerated by pip-compile with Python 3.10
# by the following command:
#
# pip-compile --allow-unsafe --no-annotate .riot/requirements/fbe6b3d.in
#
aiokafka==0.11.0
async-timeout==4.0.3
attrs==24.2.0
coverage[toml]==7.6.1
exceptiongroup==1.2.2
hypothesis==6.45.0
iniconfig==2.0.0
mock==5.1.0
opentracing==2.4.0
packaging==24.1
pluggy==1.5.0
pytest==8.3.2
pytest-asyncio==0.23.8
pytest-cov==5.0.0
pytest-mock==3.14.0
pytest-randomly==3.15.0
sortedcontainers==2.4.0
tomli==2.0.1
typing-extensions==4.12.2
24 changes: 24 additions & 0 deletions .riot/requirements/fe1d595.txt
Original file line number Diff line number Diff line change
@@ -0,0 +1,24 @@
#
# This file is autogenerated by pip-compile with Python 3.14
# by the following command:
#
# pip-compile --allow-unsafe --no-annotate .riot/requirements/fe1d595.in
#
aiokafka==0.12.0
async-timeout==5.0.1
attrs==25.4.0
coverage[toml]==7.11.0
hypothesis==6.45.0
iniconfig==2.3.0
mock==5.2.0
opentracing==2.4.0
packaging==25.0
pluggy==1.6.0
pygments==2.19.2
pytest==8.4.2
pytest-asyncio==1.2.0
pytest-cov==7.0.0
pytest-mock==3.15.1
pytest-randomly==4.0.1
sortedcontainers==2.4.0
typing-extensions==4.15.0
1 change: 1 addition & 0 deletions ddtrace/_monkey.py
Original file line number Diff line number Diff line change
Expand Up @@ -59,6 +59,7 @@
"kafka": True,
"langgraph": True,
"litellm": True,
"aiokafka": True,
"mongoengine": True,
"mysql": True,
"mysqldb": True,
Expand Down
Loading
Loading