Added impl to test TestConsumerGroupsAlgebra

ps-dev · May 21, 2024 · 593acab · 593acab
1 parent 4319877
commit 593acab
Showing 1 changed file with 5 additions and 6 deletions.
diff --git a/ingestors/kafka/src/main/scala/hydra/kafka/algebras/ConsumerGroupsAlgebra.scala b/ingestors/kafka/src/main/scala/hydra/kafka/algebras/ConsumerGroupsAlgebra.scala
@@ -98,12 +98,11 @@ final case class TestConsumerGroupsAlgebra(consumerGroupMap: Map[TopicConsumerKe
 
   override def getUniquePerNodeConsumerGroup: String = "uniquePerNodeConsumerGroup"
 
-  override def getOffsetsForInternalCGTopic: IO[PartitionOffsetsWithTotalLag] = ???
-//  {
-//    IO.pure(PartitionOffsetsWithTotalLag(60, 30, 30, 50,
-//      List(PartitionOffset(1,10,20,10), PartitionOffset(2,10,20,10), PartitionOffset(3,10,20,10))
-//    ))
-//  }
+  override def getOffsetsForInternalCGTopic: IO[PartitionOffsetsWithTotalLag] = {
+    IO.pure(PartitionOffsetsWithTotalLag(60, 30, 30, 50,
+      List(PartitionOffset(1,10,20,10), PartitionOffset(2,10,20,10), PartitionOffset(3,10,20,10))
+    ))
+  }
 }
 
 object TestConsumerGroupsAlgebra {