From 63561873754c4ae0b75419a89b556546c8fc6196 Mon Sep 17 00:00:00 2001
From: Steven van Beelen <steven.vanbeelen@axoniq.io>
Date: Mon, 11 Mar 2024 13:46:04 +0100
Subject: [PATCH] Delegate clientInstanceId(Duration) operation

Delegate clientInstanceId(Duration) operation according to the
introduction of this new method in 3.7.0 of Kafka.

#497
---
 .../eventhandling/producer/DefaultProducerFactory.java      | 6 ++++++
 1 file changed, 6 insertions(+)

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 6e606d05..1970c262 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();