Merge pull request #156 from wepay/Waltz-0.12.1

Waltz version 0.12.1

Author: hrdlotom

build.gradle

@@ -22,7 +22,7 @@ project.ext {
     assertjVersion = '3.8.0'
     zkToolsVersion = '0.7.3'
     yamlVersion = '1.20'
-    riffVersion = '2.5.0'
+    riffVersion = '2.5.1'
     jacksonVersion = '2.9.6'
     jettyVersion = '9.4.12.v20180830'
     mainClass = 'Main'

gradle.properties

@@ -1,3 +1,3 @@
 group=com.wepay.waltz
 sourceCompatibility=1.8
-version=0.12.0
+version=0.12.1

waltz-server/src/main/java/com/wepay/waltz/server/internal/WaltzServerHandler.java

@@ -241,7 +241,7 @@ public void onChannelInactive() {
                         partitionClientsNotRemoved.add(partition.partitionId);
                     }
                 }
-                if (!partitionClientsNotRemoved.isEmpty()) {
+                if (!partitionClientsNotRemoved.isEmpty() && handler.clientId != null && handler.clientId != -1) {
                     LOGGER.info(String.format("WaltzServerHandler ClientId: %d, SeqNum: %d, partitionClientsNotRemoved: %s",
                         handler.clientId, handler.seqNum, partitionClientsNotRemoved));
                 }