Skip to content

[pull] master from DataDog:master#574

Merged
pull[bot] merged 1 commit into
ConnectionMaster:masterfrom
DataDog:master
Jun 2, 2026
Merged

[pull] master from DataDog:master#574
pull[bot] merged 1 commit into
ConnectionMaster:masterfrom
DataDog:master

Conversation

@pull

@pull pull Bot commented Jun 2, 2026

Copy link
Copy Markdown

See Commits and Changes for more details.


Created by pull[bot] (v2.0.0-alpha.4)

Can you help keep this open source service alive? 💖 Please sponsor : )

* Add broker list to kafka_consumer cluster monitoring heartbeat

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

* Add changelog entry for PR #23898

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

* Address review comments on heartbeat broker list

- Extract _get_broker_list() helper to separate topology-transform from payload-assembly
- Use broker_meta.id instead of dict key; cast to str to match broker config event convention
- Add tests for heartbeat brokers payload (populated and empty cases)

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

* Fix _cluster_metadata not set on create_autospec mock in tests

seed_mock_kafka_client uses create_autospec(KafkaClient), which does not
expose instance attributes set in __init__. Setting _cluster_metadata
directly on the mock fixture makes it available to _get_broker_list().

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

---------

Co-authored-by: Claude Sonnet 4.6 <noreply@anthropic.com>
@pull pull Bot locked and limited conversation to collaborators Jun 2, 2026
@pull pull Bot added the ⤵️ pull label Jun 2, 2026
@pull pull Bot merged commit ed51a88 into ConnectionMaster:master Jun 2, 2026
8 of 11 checks passed
@pull pull Bot had a problem deploying to typo-squatting-release June 2, 2026 07:24 Failure
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant