diff --git a/kafka/src/main/java/org/axonframework/extensions/kafka/eventhandling/producer/DefaultProducerFactory.java b/kafka/src/main/java/org/axonframework/extensions/kafka/eventhandling/producer/DefaultProducerFactory.java
index 6e606d0..1970c26 100644
--- a/kafka/src/main/java/org/axonframework/extensions/kafka/eventhandling/producer/DefaultProducerFactory.java
+++ b/kafka/src/main/java/org/axonframework/extensions/kafka/eventhandling/producer/DefaultProducerFactory.java
@@ -28,6 +28,7 @@
 import org.apache.kafka.common.MetricName;
 import org.apache.kafka.common.PartitionInfo;
 import org.apache.kafka.common.TopicPartition;
+import org.apache.kafka.common.Uuid;
 import org.apache.kafka.common.errors.ProducerFencedException;
 import org.axonframework.common.AxonConfigurationException;
 import org.slf4j.Logger;
@@ -264,6 +265,11 @@ public void abortTransaction() throws ProducerFencedException {
             this.delegate.abortTransaction();
         }
 
+        @Override
+        public Uuid clientInstanceId(Duration duration) {
+            return delegate.clientInstanceId(duration);
+        }
+
         @Override
         public void close() {
             this.delegate.close();