diff --git a/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/producer/SpringwolfKafkaProducer.java b/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/producer/SpringwolfKafkaProducer.java
index ff404de62..444943a0e 100644
--- a/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/producer/SpringwolfKafkaProducer.java
+++ b/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/producer/SpringwolfKafkaProducer.java
@@ -27,7 +27,7 @@ public boolean isEnabled() {
 
     public void send(String topic, String key, Map<String, String> headers, Object payload) {
         if (kafkaTemplate.isPresent()) {
-            kafkaTemplate.get().send(buildProducerRecord(topic, key, headers, payload)).completable().join();
+            kafkaTemplate.get().send(buildProducerRecord(topic, key, headers, payload)).toCompletableFuture().join();
         } else {
             log.warn("Kafka producer is not configured");
         }