Skip to content

[pull] master from DataDog:master#494

Merged
pull[bot] merged 4 commits into
ConnectionMaster:masterfrom
DataDog:master
Apr 22, 2026
Merged

[pull] master from DataDog:master#494
pull[bot] merged 4 commits into
ConnectionMaster:masterfrom
DataDog:master

Conversation

@pull

@pull pull Bot commented Apr 22, 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 : )

coignetp and others added 4 commits April 22, 2026 14:29
* Set display_priority in mysql spec.yaml based on field usage

* Add changelog entry for mysql

* Update display_priority in mysql spec.yaml (enforce host/port and username/password adjacency)

* Update display_priority in mysql: host/port/username/password as one group

* Reorder fields in mysql spec.yaml by display_priority

* Regenerate conf.yaml.example for mysql

* Update display_priority in mysql spec.yaml based on field usage

* Sync conf.yaml.example with spec.yaml
…rds (#23409)

* kafka_consumer: purge stale broker_timestamps when offsets go backwards

When a topic's highwater offset decreases (retention wipe, topic
recreation, or offset reset), the cached (offset, timestamp) pairs with
offsets above the new highwater no longer correspond to real messages.
_get_interpolated_timestamp then extrapolates between those stale pairs
and fresh ones, pinning estimated_consumer_lag to a wall-clock value
equal to how long ago the reset happened (e.g. a steady ~18h lag
reading while kafka.consumer_lag shows only ~170 offsets).

Fix _add_broker_timestamps to:
  - drop cached entries with offsets above the new highwater
  - evict by oldest timestamp rather than smallest offset, so fresh
    post-reset entries are kept over poisonous stale ones.

* Add changelog fragment
* [kafka_actions] Remove unused MessageFilter class

MessageFilter was never imported or instantiated. Filtering is done via
the jq-style _evaluate_filter path in check.py.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

* Add changelog entry

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

* Delete kafka_actions/changelog.d/23430.changed

* changelog

---------

Co-authored-by: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
@pull pull Bot locked and limited conversation to collaborators Apr 22, 2026
@pull pull Bot added the ⤵️ pull label Apr 22, 2026
@pull pull Bot merged commit ca5813a into ConnectionMaster:master Apr 22, 2026
1 check passed
@pull pull Bot had a problem deploying to typo-squatting-release April 23, 2026 05:30 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.

3 participants