Merge pull request #2753 from ozangunalp/kafka_3.8.0_compatibility

Kafka 3.8.0 compatibility
smallrye · Sep 23, 2024 · 25dcdf8 · 25dcdf8
2 parents fff37d8 + 416df68
commit 25dcdf8
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...fka/src/test/java/io/smallrye/reactive/messaging/kafka/fault/KafkaFailureHandlerTest.java b/...fka/src/test/java/io/smallrye/reactive/messaging/kafka/fault/KafkaFailureHandlerTest.java
@@ -39,6 +39,7 @@
 import org.apache.kafka.clients.producer.ProducerRecord;
 import org.apache.kafka.common.TopicPartition;
 import org.apache.kafka.common.errors.RecordDeserializationException;
+import org.apache.kafka.common.serialization.DoubleDeserializer;
 import org.apache.kafka.common.serialization.IntegerDeserializer;
 import org.apache.kafka.common.serialization.IntegerSerializer;
 import org.eclipse.microprofile.reactive.messaging.Incoming;
@@ -284,7 +285,8 @@ public void testDeadLetterQueueStrategyWithKeyDeserializationError() {
         MyReceiverBean bean = runApplication(getDeadLetterQueueConfig(topic)
                 .with("dead-letter-queue.topic", dlqTopic)
                 .with("fail-on-deserialization-failure", false)
-                .with("key.deserializer.encoding", "unknown-encoding"), MyReceiverBean.class);
+                .with("key.deserializer", DoubleDeserializer.class.getName()) // wrong key deserializer
+                , MyReceiverBean.class);
         await().until(this::isReady);
 
         companion.produce(Integer.class, String.class)