diff --git a/src/main/java/org/zalando/nakadi/service/subscription/zk/AbstractZkSubscriptionClient.java b/src/main/java/org/zalando/nakadi/service/subscription/zk/AbstractZkSubscriptionClient.java
index 228d974775..767dbdb43c 100644
--- a/src/main/java/org/zalando/nakadi/service/subscription/zk/AbstractZkSubscriptionClient.java
+++ b/src/main/java/org/zalando/nakadi/service/subscription/zk/AbstractZkSubscriptionClient.java
@@ -478,4 +478,9 @@ protected abstract byte[] createTopologyAndOffsets(Collection<SubscriptionCursor
     protected abstract byte[] serializeSession(Session session) throws NakadiRuntimeException;
 
     protected abstract Session deserializeSession(String sessionId, byte[] sessionZkData) throws NakadiRuntimeException;
+
+    @Override
+    public void close() throws IOException {
+        getCloseableCuratorFramework().close();
+    }
 }
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 39b8da545d..b1108dffbb 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
@@ -216,9 +216,4 @@ public void transfer(final String sessionId, final Collection<EventTypePartition
                     changeSet.toArray(new Partition[changeSet.size()]));
         }
     }
-
-    @Override
-    public void close() throws IOException {
-        getCloseableCuratorFramework().close();
-    }
 }