You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@ozone.apache.org by "gardenia (via GitHub)" <gi...@apache.org> on 2026/06/15 12:43:01 UTC
[PR] HDDS-15564. EventNotification: async kafka notification sending [ozone]
gardenia opened a new pull request, #10517:
URL: https://github.com/apache/ozone/pull/10517
Please describe your PR in detail:
* Replaced the initial blocking Kafka send/checkpoint update implementation in `OMEventListenerKafkaPublisher` with an async send which updates the checkpointing position when the sends are acknowledged.
* In-flight transaction acknowledgements are tracked in-memory using a sliding-window companion, and the checkpointing position is only advanced to the highest contiguous acknowledged transaction index (preserving "at-least-once" delivery guarantees).
* Added a flow-control backpressure limit (default: 1,000) for the in-flight transaction tracking. If the limit is reached, the poller thread will block until the window drains.
## What is the link to the Apache JIRA
https://issues.apache.org/jira/browse/HDDS-15564
## How was this patch tested?
Unit tests:
* `TestOMEventListenerKafkaPublisher.testAsyncSlidingWindowWatermark` (validated out-of-order ack progress)
* `TestOMEventListenerKafkaPublisher.testAsyncSendFailureHaltsWatermark` (validated broker failure-halting and idempotent poller retries)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@ozone.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@ozone.apache.org
For additional commands, e-mail: issues-help@ozone.apache.org
Re: [PR] HDDS-15564. EventNotification: async kafka notification sending [ozone]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] closed pull request #10517: HDDS-15564. EventNotification: async kafka notification sending
URL: https://github.com/apache/ozone/pull/10517
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@ozone.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@ozone.apache.org
For additional commands, e-mail: issues-help@ozone.apache.org
Re: [PR] HDDS-15564. EventNotification: async kafka notification sending [ozone]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on PR #10517:
URL: https://github.com/apache/ozone/pull/10517#issuecomment-4975384358
Thank you for your contribution. This PR is being closed due to inactivity. Please contact a maintainer if you would like to reopen it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@ozone.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@ozone.apache.org
For additional commands, e-mail: issues-help@ozone.apache.org
Re: [PR] HDDS-15564. EventNotification: async kafka notification sending [ozone]
Posted by "gardenia (via GitHub)" <gi...@apache.org>.
gardenia commented on PR #10517:
URL: https://github.com/apache/ozone/pull/10517#issuecomment-4709955208
@ChenSammi FYI
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@ozone.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@ozone.apache.org
For additional commands, e-mail: issues-help@ozone.apache.org
Re: [PR] HDDS-15564. EventNotification: async kafka notification sending [ozone]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on PR #10517:
URL: https://github.com/apache/ozone/pull/10517#issuecomment-4898859833
This PR has been marked as stale due to 21 days of inactivity. Please comment or remove the stale label to keep it open. Otherwise, it will be automatically closed in 7 days.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscribe@ozone.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@ozone.apache.org
For additional commands, e-mail: issues-help@ozone.apache.org