Fix kafkaTemplate.send after rebasing

springwolf · Mar 12, 2023 · a951dac · a951dac
1 parent c3780b2
commit a951dac
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...lugin/src/main/java/io/github/stavshamir/springwolf/producer/SpringwolfKafkaProducer.java b/...lugin/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");
         }