diff --git a/src/main/java/org/zalando/nakadi/service/subscription/zk/NewZkSubscriptionClient.java b/src/main/java/org/zalando/nakadi/service/subscription/zk/NewZkSubscriptionClient.java
index 2ae06ff5b3..d68882c3ed 100644
--- a/src/main/java/org/zalando/nakadi/service/subscription/zk/NewZkSubscriptionClient.java
+++ b/src/main/java/org/zalando/nakadi/service/subscription/zk/NewZkSubscriptionClient.java
@@ -174,17 +174,6 @@ public Map<EventTypePartition, SubscriptionCursorWithoutToken> getOffsets(
                 new SubscriptionCursorWithoutToken(etp.getEventType(), etp.getPartition(), new String(value, UTF_8)));
     }
 
-    protected Session deserializeSession(final String sessionId, final byte[] sessionZkData) throws IOException {
-        try {
-            // old version of session: zkNode data is session weight
-            final int weight = Integer.parseInt(new String(sessionZkData, UTF_8));
-            return new Session(sessionId, weight);
-        } catch (final NumberFormatException nfe) {
-            // new version of session: zkNode data is session object as json
-            return objectMapper.readValue(sessionZkData, Session.class);
-        }
-    }
-
     @Override
     public void transfer(final String sessionId, final Collection<EventTypePartition> partitions)
             throws NakadiRuntimeException, SubscriptionNotInitializedException {