From 7fc257f5b86342f70760795590bc979d38e43d6a Mon Sep 17 00:00:00 2001
From: dsorokin <dmitry.sorokin@gmail.com>
Date: Fri, 24 Nov 2017 21:22:05 +0100
Subject: [PATCH] ARUHA-1340 Remove topology logging on cursors commit

---
 .../service/subscription/zk/NewZkSubscriptionClient.java    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

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 da529a1f81..9f52041756 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
@@ -82,6 +82,7 @@ protected byte[] createTopologyAndOffsets(final Collection<SubscriptionCursorWit
                 Partition.State.UNASSIGNED
         )).toArray(Partition[]::new);
         final Topology topology = new Topology(partitions, 0);
+        getLog().info("Generating topology {}", topology);
         return objectMapper.writeValueAsBytes(topology);
     }
 
@@ -90,6 +91,7 @@ public void updatePartitionsConfiguration(final Partition[] partitions) throws N
             SubscriptionNotInitializedException {
         final Topology newTopology = readTopology().withUpdatedPartitions(partitions);
         try {
+            getLog().info("Updating topology to {}", newTopology);
             getCurator().setData().forPath(
                     getSubscriptionPath(NODE_TOPOLOGY),
                     objectMapper.writeValueAsBytes(newTopology));
@@ -111,9 +113,7 @@ private Topology readTopology() throws NakadiRuntimeException,
 
     private Topology parseTopology(final byte[] data) {
         try {
-            final Topology result = objectMapper.readValue(data, Topology.class);
-            getLog().info("Topology is {}", result);
-            return result;
+            return objectMapper.readValue(data, Topology.class);
         } catch (IOException e) {
             throw new NakadiRuntimeException(e);
         }