diff --git a/confluent_client/bin/nodediscover b/confluent_client/bin/nodediscover
index 6838b911..ea93f298 100755
--- a/confluent_client/bin/nodediscover
+++ b/confluent_client/bin/nodediscover
@@ -53,6 +53,7 @@ columnmapping = {
 async def register_endpoint(options, session, addr):
     neednewline = False
     current = 0
+    total = 0
     async for rsp in session.update('/discovery/register', {'addresses': addr}):
         if 'count' in rsp:
             total = rsp['count']