Skip to content
This repository has been archived by the owner on Nov 15, 2024. It is now read-only.

Adapt1 1533 | Use offset-streams to check lag in internal topic #24

Merged
merged 5 commits into from
May 8, 2024

Conversation

abhivermaaa
Copy link

[Adapt1 1533] | Use offset-streams to check lag in internal topic

Description :
This Pull Request is having code changes for :

  • the creation of Consumer group offset facade which should hold the partition level group offsets from offset stream.
  • reading the offset stream and updating the facade with partition level group offsets for "_hydra.consumer-groups".
  • the creation of a new endpoint which should return the partition level group offsets, largest offsets, lag for all partitions which are having any records.

Jira :
https://pluralsight.atlassian.net/browse/ADAPT1-1533

… aand also added ConsumerGroupsOffsetFacade for holding all offset info
… consumer topic partition offset map | Added changes for using offset stream and updating the consumer group offset facade
Copy link

@aman-minz aman-minz left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@abhivermaaa abhivermaaa merged commit ef340e1 into feature-notification-subscribertab May 8, 2024
2 checks passed
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants