diff --git a/kubernetes-client-api/src/test/java/io/fabric8/kubernetes/client/http/AbstractInterceptorTest.java b/kubernetes-client-api/src/test/java/io/fabric8/kubernetes/client/http/AbstractInterceptorTest.java
index 93c88e37751..f85ded10834 100644
--- a/kubernetes-client-api/src/test/java/io/fabric8/kubernetes/client/http/AbstractInterceptorTest.java
+++ b/kubernetes-client-api/src/test/java/io/fabric8/kubernetes/client/http/AbstractInterceptorTest.java
@@ -225,10 +225,12 @@ public CompletableFuture<Boolean> afterFailure(BasicBuilder builder, HttpRespons
         });
     // When
     try (HttpClient client = builder.build()) {
-      client.consumeBytes(
+      final HttpResponse<AsyncBody> asyncR = client.consumeBytes(
           client.newHttpRequestBuilder().uri(server.url("/not-found")).build(),
           (s, ab) -> ab.consume())
           .get(10, TimeUnit.SECONDS);
+      asyncR.body().consume();
+      asyncR.body().done().get(10L, TimeUnit.SECONDS);
     }
     // Then
     assertThat(interceptedResponses)
@@ -279,10 +281,12 @@ public void after(HttpRequest request, HttpResponse<?> response, Consumer<List<B
         });
     // When
     try (HttpClient client = builder.build()) {
-      client.consumeBytes(
+      final HttpResponse<AsyncBody> asyncR = client.consumeBytes(
           client.newHttpRequestBuilder().uri(server.url("/success")).build(),
           (s, ab) -> ab.consume())
           .get(10, TimeUnit.SECONDS);
+      asyncR.body().consume();
+      asyncR.body().done().get(10L, TimeUnit.SECONDS);
     }
     // Then
     assertThat(responseFuture)
@@ -306,10 +310,12 @@ public void after(HttpRequest request, HttpResponse<?> response, Consumer<List<B
         });
     // When
     try (HttpClient client = builder.build()) {
-      client.consumeBytes(
+      final HttpResponse<AsyncBody> asyncR = client.consumeBytes(
           client.newHttpRequestBuilder().uri(server.url("/client-error")).build(),
           (s, ab) -> ab.consume())
           .get(10, TimeUnit.SECONDS);
+      asyncR.body().consume();
+      asyncR.body().done().get(10L, TimeUnit.SECONDS);
     }
     // Then
     assertThat(responseFuture)
diff --git a/kubernetes-client-api/src/test/java/io/fabric8/kubernetes/client/http/AbstractSimultaneousConnectionsTest.java b/kubernetes-client-api/src/test/java/io/fabric8/kubernetes/client/http/AbstractSimultaneousConnectionsTest.java
index 5ae56d15d65..6b940fa4a63 100644
--- a/kubernetes-client-api/src/test/java/io/fabric8/kubernetes/client/http/AbstractSimultaneousConnectionsTest.java
+++ b/kubernetes-client-api/src/test/java/io/fabric8/kubernetes/client/http/AbstractSimultaneousConnectionsTest.java
@@ -118,7 +118,11 @@ public void http1Connections() throws Exception {
       assertThat(asyncResponses)
           .hasSize(MAX_HTTP_1_CONNECTIONS)
           .extracting(CompletableFuture::join)
-          .extracting(HttpResponse::code).containsOnly(204);
+          .extracting(response -> {
+            response.body().consume();
+            return response.code();
+          })
+          .containsOnly(204);
     }
   }