Skip to content

Conversation

@sakurai-youhei
Copy link
Member

This PR is still WIP.

What does this pull request do?

This PR adds AIOKafkaInstrumentation to instrument aiokafka.

Related issues

n/a

Notes for reviewers

  • This feature addition is a nice-to-have.
  • Most of the tests are based on the existing kafka_tests.py. For similarities and differences, refer to the output of git diff --no-index tests/instrumentation/kafka_tests.py tests/instrumentation/asyncio_tests/aiokafka_tests.py.
  • The following four tests are added entirely new:
    1, test_aiokafka_getmany_multiple_topics: getmany() is a unique feature of aiokafka.
    2. test_aiokafka_send_batch: send_batch() is also a unique feature of aiokafka.
    3. test_aiokafka_consumer_non_recording_transaction: A test to increase coverage.
    4. test_aiokafka_inject_trace_parent_into_send_arguments: A test that thoroughly checks the most complicated part.

@github-actions
Copy link

github-actions bot commented Jan 2, 2026

🤖 GitHub comments

Just comment with:

  • run docs-build : Re-trigger the docs validation. (use unformatted text in the comment!)

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant