debug group/topic removal issues

allegro · Aug 14, 2024 · ed38792 · ed38792
1 parent f445b92
commit ed38792
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/...c/main/java/pl/allegro/tech/hermes/infrastructure/zookeeper/ZookeeperGroupRepository.java b/...c/main/java/pl/allegro/tech/hermes/infrastructure/zookeeper/ZookeeperGroupRepository.java
@@ -82,6 +82,7 @@ public void removeGroup(String groupName) {
                 paths.groupPath(groupName)
         );
         try {
+            logger.info("During group removal will remove paths: {}", pathsToDelete);
             deleteInTransaction(pathsToDelete);
         } catch (Exception e) {
             logger.info("Failed to remove group: {}, children: {}", groupName, allChildrenPathsOf(paths.groupPath(groupName)));

diff --git a/...c/main/java/pl/allegro/tech/hermes/infrastructure/zookeeper/ZookeeperTopicRepository.java b/...c/main/java/pl/allegro/tech/hermes/infrastructure/zookeeper/ZookeeperTopicRepository.java
@@ -138,6 +138,7 @@ public void removeTopic(TopicName topicName) {
         pathsForRemoval.add(paths.topicPath(topicName));
 
         try {
+            logger.info("During topic removal will remove paths: {}", pathsForRemoval);
             deleteInTransaction(pathsForRemoval);
         } catch (Exception e) {
             logger.info("Failed to remove topic: {}, children: {}", topicName, allChildrenPathsOf(paths.topicPath(topicName)));