ADS-1063. Change TrieMaps to Caffeine Cache with expiration timeout.

arenadata · Jun 21, 2023 · 57a38e1 · 57a38e1
1 parent 71af2df
commit 57a38e1
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/app/kafka/manager/actor/cluster/KafkaStateActor.scala b/app/kafka/manager/actor/cluster/KafkaStateActor.scala
@@ -416,6 +416,10 @@ case class KafkaManagedOffsetCache(clusterContext: ClusterContext
     groupTopicPartitionOffsetSet.clear()
     groupTopicPartitionOffsetMap.invalidateAll()
     groupTopicPartitionOffsetMap.cleanUp()
+    topicConsumerSetMap.invalidateAll();
+    topicConsumerSetMap.cleanUp();
+    consumerTopicSetMap.invalidateAll();
+    consumerTopicSetMap.cleanUp();
     info(s"KafkaManagedOffsetCache shut down for cluster ${clusterContext.config.name}")
   }