diff --git a/VERSION b/VERSION
index 5e32542..88d06f1 100644
--- a/VERSION
+++ b/VERSION
@@ -1 +1 @@
-6.1.2
+6.1.3
diff --git a/voltha/voltha-kafka-dump/callprotoc.py b/voltha/voltha-kafka-dump/callprotoc.py
index 453d97a..9e756b7 100644
--- a/voltha/voltha-kafka-dump/callprotoc.py
+++ b/voltha/voltha-kafka-dump/callprotoc.py
@@ -48,9 +48,8 @@
         buf = buf + in_bytes
         while b"===VOLTHA-DELIM===" in buf:
             (part, buf) = buf.split(b"===VOLTHA-DELIM===", 1)
-            if first:
-                first = False
             call_protoc(part, msgName, protoFileName, includeDir, first)
+            first = False
         in_bytes = sys.stdin.buffer.read(1)
 
     # there is likely one trailing message still to print