This repository was archived by the owner on Nov 15, 2024. It is now read-only.

[Adapt1-1545] | Publish lag on consumer group internal topic as per the configured time for each node - #28

Open

abhivermaaa wants to merge 20 commits into

Commits on Apr 21, 2024

Added an offset stream which will be having all committed offset info aand also added ConsumerGroupsOffsetFacade for holding all offset info
abhivermaaa
committed
d179477
returning empty fs2.stream instead of no implementation
abhivermaaa
committed
9e43eed

Commits on May 8, 2024

Commits on May 10, 2024

Refactored the getOffsetsForInternalCGTopic which is getting offset data from cache | optimized the method | Added code to remove the partitions having 0 latest offset | partition level lag is calu…
abhivermaaa
committed
d67bd93

Commits on May 13, 2024

Created a new response having consolidated lags and lag percentage | Added marshalling logic for new case object in ingestors/kafka/src/main/scala/hydra/kafka/marshallers/ConsumerGroupMarshallers.s…
abhivermaaa
committed
dba86d2

Commits on May 14, 2024

Added offset change code for starting with 0 | Add code to marshaller for new case object
abhivermaaa
committed
ad8a210

Commits on May 21, 2024

Commits on May 29, 2024

Adding changes
abhivermaaa
committed
02efd85

Commits on Jun 5, 2024

Refactored code to have a single stream and adjusted updation of cache one after the other. First Consumer group storage facade is getting updated then just after that consumer group offset facade.
abhivermaaa
committed
bc7c6f7

Commits on Jun 6, 2024

Commits on Jun 10, 2024

Added a comment and Added active partition count in the logger
abhivermaaa
committed
74f962d

Commits on Jun 11, 2024

limitting decimal places in the lag logger
abhivermaaa
committed
35eb28d