Handled the exception to respond with a Future.fail

Author: barbaros-alp-irdeto

src/main/java/io/vertx/kafka/client/consumer/impl/KafkaConsumerImpl.java

@@ -389,7 +389,14 @@ public KafkaConsumer<K, V> partitionsFor(String topic, Handler<AsyncResult<List<
       if (done.succeeded()) {
         // TODO: use Helper class and stream approach
         List<PartitionInfo> partitions = new ArrayList<>();
-        for (org.apache.kafka.common.PartitionInfo kafkaPartitionInfo: done.result()) {
+        List<org.apache.kafka.common.PartitionInfo> partitionInfos;
+        try {
+          partitionInfos = done.result();
+        } catch (Exception e) {
+          handler.handle(Future.failedFuture(e));
+          return;
+        }
+        for (org.apache.kafka.common.PartitionInfo kafkaPartitionInfo: partitionInfos) {
 
           PartitionInfo partitionInfo = new PartitionInfo();