Skip to content

Commit dbe8eb7

Browse files
feat(aiokafka): add APM support for aiokafka (#15111)
## Description - Introduces new aiokafka integration providing instrumentation for `AIOKafkaProducer.send,` `AIOKafkaConsumer.getone/getmany`, and `commit`. - Supports optional distributed tracing via message headers when `DD_KAFKA_PROPAGATION_ENABLED=true`. DSM support will be added in a follow-up PR. ## Testing Added snapshot tests in `test_aiokafka.py` This is a follow up of #10068 Thanks for your initial initial contribution @ls-pieter-vanisacker --------- Co-authored-by: Pieter Van Isacker <pieter.vanisacker@lightspeedhq.com>
1 parent 30d88d9 commit dbe8eb7

File tree

40 files changed

+1943
-1
lines changed

40 files changed

+1943
-1
lines changed

.riot/requirements/13e0d21.txt

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
#
2+
# This file is autogenerated by pip-compile with Python 3.13
3+
# by the following command:
4+
#
5+
# pip-compile --allow-unsafe --no-annotate .riot/requirements/13e0d21.in
6+
#
7+
aiokafka==0.9.0
8+
async-timeout==5.0.1
9+
attrs==25.4.0
10+
coverage[toml]==7.11.0
11+
hypothesis==6.45.0
12+
iniconfig==2.3.0
13+
mock==5.2.0
14+
opentracing==2.4.0
15+
packaging==25.0
16+
pluggy==1.6.0
17+
pygments==2.19.2
18+
pytest==8.4.2
19+
pytest-asyncio==1.2.0
20+
pytest-cov==7.0.0
21+
pytest-mock==3.15.1
22+
pytest-randomly==4.0.1
23+
sortedcontainers==2.4.0

.riot/requirements/1c72bfb.txt

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
#
2+
# This file is autogenerated by pip-compile with Python 3.13
3+
# by the following command:
4+
#
5+
# pip-compile --allow-unsafe --no-annotate .riot/requirements/1c72bfb.in
6+
#
7+
aiokafka==0.12.0
8+
async-timeout==5.0.1
9+
attrs==25.4.0
10+
coverage[toml]==7.11.0
11+
hypothesis==6.45.0
12+
iniconfig==2.3.0
13+
mock==5.2.0
14+
opentracing==2.4.0
15+
packaging==25.0
16+
pluggy==1.6.0
17+
pygments==2.19.2
18+
pytest==8.4.2
19+
pytest-asyncio==1.2.0
20+
pytest-cov==7.0.0
21+
pytest-mock==3.15.1
22+
pytest-randomly==4.0.1
23+
sortedcontainers==2.4.0
24+
typing-extensions==4.15.0

.riot/requirements/1ded764.txt

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
#
2+
# This file is autogenerated by pip-compile with Python 3.14
3+
# by the following command:
4+
#
5+
# pip-compile --allow-unsafe --no-annotate .riot/requirements/1ded764.in
6+
#
7+
aiokafka==0.9.0
8+
async-timeout==5.0.1
9+
attrs==25.4.0
10+
coverage[toml]==7.11.0
11+
hypothesis==6.45.0
12+
iniconfig==2.3.0
13+
mock==5.2.0
14+
opentracing==2.4.0
15+
packaging==25.0
16+
pluggy==1.6.0
17+
pygments==2.19.2
18+
pytest==8.4.2
19+
pytest-asyncio==1.2.0
20+
pytest-cov==7.0.0
21+
pytest-mock==3.15.1
22+
pytest-randomly==4.0.1
23+
sortedcontainers==2.4.0

.riot/requirements/329b0ed.txt

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
#
2+
# This file is autogenerated by pip-compile with Python 3.12
3+
# by the following command:
4+
#
5+
# pip-compile --allow-unsafe --no-annotate .riot/requirements/329b0ed.in
6+
#
7+
aiokafka==0.9.0
8+
async-timeout==5.0.1
9+
attrs==25.4.0
10+
coverage[toml]==7.11.0
11+
hypothesis==6.45.0
12+
iniconfig==2.3.0
13+
mock==5.2.0
14+
opentracing==2.4.0
15+
packaging==25.0
16+
pluggy==1.6.0
17+
pygments==2.19.2
18+
pytest==8.4.2
19+
pytest-asyncio==1.2.0
20+
pytest-cov==7.0.0
21+
pytest-mock==3.15.1
22+
pytest-randomly==4.0.1
23+
sortedcontainers==2.4.0
24+
typing-extensions==4.15.0

.riot/requirements/4532043.txt

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
#
2+
# This file is autogenerated by pip-compile with Python 3.11
3+
# by the following command:
4+
#
5+
# pip-compile --allow-unsafe --no-annotate .riot/requirements/4532043.in
6+
#
7+
aiokafka==0.12.0
8+
async-timeout==5.0.1
9+
attrs==25.4.0
10+
coverage[toml]==7.11.0
11+
hypothesis==6.45.0
12+
iniconfig==2.3.0
13+
mock==5.2.0
14+
opentracing==2.4.0
15+
packaging==25.0
16+
pluggy==1.6.0
17+
pygments==2.19.2
18+
pytest==8.4.2
19+
pytest-asyncio==1.2.0
20+
pytest-cov==7.0.0
21+
pytest-mock==3.15.1
22+
pytest-randomly==4.0.1
23+
sortedcontainers==2.4.0
24+
typing-extensions==4.15.0

.riot/requirements/538f024.txt

Lines changed: 29 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,29 @@
1+
#
2+
# This file is autogenerated by pip-compile with Python 3.9
3+
# by the following command:
4+
#
5+
# pip-compile --allow-unsafe --no-annotate .riot/requirements/538f024.in
6+
#
7+
aiokafka==0.9.0
8+
async-timeout==5.0.1
9+
attrs==25.4.0
10+
backports-asyncio-runner==1.2.0
11+
coverage[toml]==7.10.7
12+
exceptiongroup==1.3.0
13+
hypothesis==6.45.0
14+
importlib-metadata==8.7.0
15+
iniconfig==2.1.0
16+
mock==5.2.0
17+
opentracing==2.4.0
18+
packaging==25.0
19+
pluggy==1.6.0
20+
pygments==2.19.2
21+
pytest==8.4.2
22+
pytest-asyncio==1.2.0
23+
pytest-cov==7.0.0
24+
pytest-mock==3.15.1
25+
pytest-randomly==4.0.1
26+
sortedcontainers==2.4.0
27+
tomli==2.3.0
28+
typing-extensions==4.15.0
29+
zipp==3.23.0

.riot/requirements/65c09d3.txt

Lines changed: 29 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,29 @@
1+
#
2+
# This file is autogenerated by pip-compile with Python 3.9
3+
# by the following command:
4+
#
5+
# pip-compile --allow-unsafe --no-annotate .riot/requirements/65c09d3.in
6+
#
7+
aiokafka==0.12.0
8+
async-timeout==5.0.1
9+
attrs==25.4.0
10+
backports-asyncio-runner==1.2.0
11+
coverage[toml]==7.10.7
12+
exceptiongroup==1.3.0
13+
hypothesis==6.45.0
14+
importlib-metadata==8.7.0
15+
iniconfig==2.1.0
16+
mock==5.2.0
17+
opentracing==2.4.0
18+
packaging==25.0
19+
pluggy==1.6.0
20+
pygments==2.19.2
21+
pytest==8.4.2
22+
pytest-asyncio==1.2.0
23+
pytest-cov==7.0.0
24+
pytest-mock==3.15.1
25+
pytest-randomly==4.0.1
26+
sortedcontainers==2.4.0
27+
tomli==2.3.0
28+
typing-extensions==4.15.0
29+
zipp==3.23.0

.riot/requirements/c6f2827.txt

Lines changed: 27 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,27 @@
1+
#
2+
# This file is autogenerated by pip-compile with Python 3.10
3+
# by the following command:
4+
#
5+
# pip-compile --allow-unsafe --no-annotate .riot/requirements/c6f2827.in
6+
#
7+
aiokafka==0.9.0
8+
async-timeout==5.0.1
9+
attrs==25.4.0
10+
backports-asyncio-runner==1.2.0
11+
coverage[toml]==7.11.0
12+
exceptiongroup==1.3.0
13+
hypothesis==6.45.0
14+
iniconfig==2.3.0
15+
mock==5.2.0
16+
opentracing==2.4.0
17+
packaging==25.0
18+
pluggy==1.6.0
19+
pygments==2.19.2
20+
pytest==8.4.2
21+
pytest-asyncio==1.2.0
22+
pytest-cov==7.0.0
23+
pytest-mock==3.15.1
24+
pytest-randomly==4.0.1
25+
sortedcontainers==2.4.0
26+
tomli==2.3.0
27+
typing-extensions==4.15.0

.riot/requirements/e580d94.txt

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
#
2+
# This file is autogenerated by pip-compile with Python 3.12
3+
# by the following command:
4+
#
5+
# pip-compile --allow-unsafe --no-annotate .riot/requirements/e580d94.in
6+
#
7+
aiokafka==0.12.0
8+
async-timeout==5.0.1
9+
attrs==25.4.0
10+
coverage[toml]==7.11.0
11+
hypothesis==6.45.0
12+
iniconfig==2.3.0
13+
mock==5.2.0
14+
opentracing==2.4.0
15+
packaging==25.0
16+
pluggy==1.6.0
17+
pygments==2.19.2
18+
pytest==8.4.2
19+
pytest-asyncio==1.2.0
20+
pytest-cov==7.0.0
21+
pytest-mock==3.15.1
22+
pytest-randomly==4.0.1
23+
sortedcontainers==2.4.0
24+
typing-extensions==4.15.0

.riot/requirements/fbd9c5b.txt

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
#
2+
# This file is autogenerated by pip-compile with Python 3.11
3+
# by the following command:
4+
#
5+
# pip-compile --allow-unsafe --no-annotate .riot/requirements/fbd9c5b.in
6+
#
7+
aiokafka==0.9.0
8+
async-timeout==5.0.1
9+
attrs==25.4.0
10+
coverage[toml]==7.11.0
11+
hypothesis==6.45.0
12+
iniconfig==2.3.0
13+
mock==5.2.0
14+
opentracing==2.4.0
15+
packaging==25.0
16+
pluggy==1.6.0
17+
pygments==2.19.2
18+
pytest==8.4.2
19+
pytest-asyncio==1.2.0
20+
pytest-cov==7.0.0
21+
pytest-mock==3.15.1
22+
pytest-randomly==4.0.1
23+
sortedcontainers==2.4.0
24+
typing-extensions==4.15.0

0 commit comments

Comments
 (0)