diff --git a/vertx-spring-boot-starter-kafka/src/test/java/dev/snowdrop/vertx/kafka/it/AbstractIT.java b/vertx-spring-boot-starter-kafka/src/test/java/dev/snowdrop/vertx/kafka/it/AbstractIT.java
index dc11953..3869818 100644
--- a/vertx-spring-boot-starter-kafka/src/test/java/dev/snowdrop/vertx/kafka/it/AbstractIT.java
+++ b/vertx-spring-boot-starter-kafka/src/test/java/dev/snowdrop/vertx/kafka/it/AbstractIT.java
@@ -89,13 +89,13 @@ protected void waitForAssignmentPropagation() throws InterruptedException {
     protected  <K, V> void sendToTopic(KafkaProducer<K, V> producer, String topic, V value) {
         producer
             .send(ProducerRecord.<K, V>builder(topic, value).build())
-            .block();
+            .subscribe();
     }
 
     protected  <K, V> void sendToTopic(KafkaProducer<K, V> producer, String topic, K key, V value) {
         producer
             .send(ProducerRecord.builder(topic, value, key).build())
-            .block();
+            .subscribe();
     }
 
     private Map<String, String> addBootstrapServersToConfig(Map<String, String> config, String bootstrapServers) {