mostafa / xk6-kafka / 25287150581

79%

push

github

Added Azure Entra Support (#390)

* Refactored consumer to get access to events to support OAuth callbacks

* Handle producer events to prepare for oauth callback

* Simplify range expression

* Added supporting OAuth callback functionality

* Added OAuth token callback to Consumer

* Regenerated API docs

* Added OAuth token callback to Producer

* Added context cancellation check

* Handle context cancellation correctly

* Improved naming

* Simplify consumer timeout handling

* Do not include Event Hub port in Entra scope

* Fixed Azure Entra bugs

* Cleaned up Go Mod

* Fixed formatting

* Consolidated oauth code and fixed linter errors

* Fixed producer client events handler cancellation

* Fixed failed tests

* Suppressed Sonar Lint

* Addressed Sonar violations

* Fixed comment typo

* Added OAuth support to admin client

* Fixed Event Hub test script

* Addressed security hotspot

* Removed unused import

* Fixed import

* xk6 sync

* Fix admin client lifecycle teardown

Persist the producer handle used to bootstrap the admin client and make close idempotent so all internal resources are reliably released. Add regression tests that verify lifecycle wiring, close behavior, and post-close operation failures.

* Document Azure Entra OAuth support in README

Update the feature and FAQ documentation to include Azure Entra OAuth usage for Event Hub and point readers to the dedicated example script.

* Prettify

* gofmt

* Tune golangci-lint v2 goconst configuration

Adjust goconst thresholds and exclusions to reduce low-value noise while keeping the linter enabled, and disable deprecated gomodguard in favor of gomodguard_v2 from the default lint set.

* Regenerate api-docs

---------

Co-authored-by: Mostafa Moradian <mstfmoradian@gmail.com>

152 of 240 new or added lines in 7 files covered. (63.33%)

3756 of 4768 relevant lines covered (78.78%)

33.38 hits per line