Skip to content

HDDS-14006. EventNotification: create a plugin impl which which publishes events to Kafka#10096

Open
gardenia wants to merge 2 commits intoapache:HDDS-13513_Event_Notification_FeatureBranchfrom
gardenia:HDDS-14006
Open

HDDS-14006. EventNotification: create a plugin impl which which publishes events to Kafka#10096
gardenia wants to merge 2 commits intoapache:HDDS-13513_Event_Notification_FeatureBranchfrom
gardenia:HDDS-14006

Conversation

@gardenia
Copy link
Copy Markdown

Please describe your PR in detail:

  • Create an OMEventListener plugin implementation which publishes events to Kafka
  • a helper class OMEventListenerLedgerPoller is provided which plugin implementations can use to periodically poll for newly written CompletedRequestInfo records table and passes them them to a callback
  • OMEventListenerKafkaPublisher is a concrete implementation of OMEventListener which consumes the latest CompletedRequestInfo records, serializes them to a string and sends them to a configured kafka broker.

What is the link to the Apache JIRA

https://issues.apache.org/jira/browse/HDDS-14006

How was this patch tested?

unit tests

Colm Dougan added 2 commits April 9, 2026 11:00
@gardenia
Copy link
Copy Markdown
Author

@ChenSammi : as per #9366 I was unable to reopen that PR and so the only option was to open a new one.

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

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant