From e562e59860ad38a47a6014a8f0b68b3c873b73b9 Mon Sep 17 00:00:00 2001
From: Lauri Tulmin <ltulmin@splunk.com>
Date: Thu, 25 Jan 2024 17:02:31 +0200
Subject: [PATCH] Reactor kafka wrapper delegates to wrong method

---
 .../reactor/kafka/v1_0/InstrumentedKafkaReceiver.java           | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/instrumentation/reactor/reactor-kafka-1.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/reactor/kafka/v1_0/InstrumentedKafkaReceiver.java b/instrumentation/reactor/reactor-kafka-1.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/reactor/kafka/v1_0/InstrumentedKafkaReceiver.java
index a8342732177d..1ecb17c1ff77 100644
--- a/instrumentation/reactor/reactor-kafka-1.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/reactor/kafka/v1_0/InstrumentedKafkaReceiver.java
+++ b/instrumentation/reactor/reactor-kafka-1.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/reactor/kafka/v1_0/InstrumentedKafkaReceiver.java
@@ -59,7 +59,7 @@ public Flux<ConsumerRecord<K, V>> receiveAtmostOnce() {
   @Override
   public Flux<Flux<ConsumerRecord<K, V>>> receiveExactlyOnce(
       TransactionManager transactionManager) {
-    return actual.receiveAutoAck().map(InstrumentedKafkaReceiver::wrap);
+    return actual.receiveExactlyOnce(transactionManager).map(InstrumentedKafkaReceiver::wrap);
   }
 
   // added in 1.3.3