Fix test on producer with no ack
@@ -410,7 +410,7 @@ class AIOKafkaProducer(object):
if request.required_acks == 0:
for batch in batches.values():
batch.done()
-
+ else:
for topic, partitions in response.topics:
for partition_info in partitions:
if response.API_VERSION < 2:
