diff --git a/confluent_client/confluent/client.py b/confluent_client/confluent/client.py index 8630a217..1ea3e884 100644 --- a/confluent_client/confluent/client.py +++ b/confluent_client/confluent/client.py @@ -281,6 +281,7 @@ class Command(object): if maxnodes is None: return nsize = self.get_noderange_size(noderange) + maxnodes = int(maxnodes) if nsize > maxnodes: if nsize == 1: nodename = list(self.read(