Fix test

Author: acogoluegnes

src/test/java/com/rabbitmq/stream/impl/StreamConsumerTest.java

@@ -243,9 +243,9 @@ void consumeWithAsyncConsumerFlowControl() throws Exception {
   void asynchronousProcessingWithFlowControl() {
     int messageCount = 100_000;
     publishAndWaitForConfirms(cf, messageCount, stream);
-
-    try (ExecutorService executorService =
-        Executors.newFixedThreadPool(getRuntime().availableProcessors())) {
+    ExecutorService executorService =
+        Executors.newFixedThreadPool(getRuntime().availableProcessors());
+    try {
       CountDownLatch latch = new CountDownLatch(messageCount);
       environment.consumerBuilder().stream(stream)
           .offset(OffsetSpecification.first())
@@ -261,6 +261,8 @@ void asynchronousProcessingWithFlowControl() {
                       }))
           .build();
       assertThat(latch).is(completed());
+    } finally {
+      executorService.shutdownNow();
     }
   }