diff --git a/api/src/main/java/org/opencord/igmpproxy/IgmpStatistics.java b/api/src/main/java/org/opencord/igmpproxy/IgmpStatistics.java
index d101d60..5617017 100644
--- a/api/src/main/java/org/opencord/igmpproxy/IgmpStatistics.java
+++ b/api/src/main/java/org/opencord/igmpproxy/IgmpStatistics.java
@@ -15,17 +15,12 @@
  */
 package org.opencord.igmpproxy;
 
-import org.slf4j.Logger;
-
 import java.util.concurrent.atomic.AtomicLong;
 
-import static org.slf4j.LoggerFactory.getLogger;
-
 /**
  * Records metrics for IgmpProxy application.
  */
 public class IgmpStatistics {
-    private final Logger log = getLogger(getClass());
     private static final long RESET_VALUE = 0L;
 
     //Total number of join requests
@@ -223,7 +218,6 @@
                 failJoinReqInsuffPermissionAccessCounter.incrementAndGet();
                 break;
             default:
-                log.warn("Unhandled statistic type. {}", type);
                 break;
         }
     }
@@ -311,7 +305,6 @@
                 break;
             default:
                 value = null;
-                log.warn("Unhandled statistic type. {}", type);
                 break;
         }
         return value;
diff --git a/app/src/main/java/org/opencord/igmpproxy/impl/IgmpStatisticsManager.java b/app/src/main/java/org/opencord/igmpproxy/impl/IgmpStatisticsManager.java
index 69ba6b6..ef932ef 100644
--- a/app/src/main/java/org/opencord/igmpproxy/impl/IgmpStatisticsManager.java
+++ b/app/src/main/java/org/opencord/igmpproxy/impl/IgmpStatisticsManager.java
@@ -93,6 +93,8 @@
     private KryoNamespace statSerializer = KryoNamespace.newBuilder()
             .register(KryoNamespaces.API)
             .register(IgmpStatistics.class)
+            .register(ClusterMessage.class)
+            .register(MessageSubject.class)
             .build();
 
     //Statistics values are valid or invalid