From d1b4f33d49550ddc189c6ecd848368007626037e Mon Sep 17 00:00:00 2001
From: Aroooba <arooba.shahoor@gmail.com>
Date: Mon, 24 Jul 2023 19:41:48 +0900
Subject: [PATCH] Change block operator to subscribe in send-to-topic method

---
 .../src/test/java/dev/snowdrop/vertx/kafka/it/AbstractIT.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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) {