Merge pull request #214 from martink76/bugfix/missing-xstream-exception

Bugfix/missing xstream exception
AxonFramework · Dec 13, 2021 · f401fd9 · f401fd9
2 parents 6efd14c + 9437b22
commit f401fd9
Show file tree

Hide file tree

Showing 3 changed files with 24 additions and 3 deletions.
diff --git a/...c/test/java/org/axonframework/extensions/kafka/autoconfig/KafkaAutoConfigurationTest.java b/...c/test/java/org/axonframework/extensions/kafka/autoconfig/KafkaAutoConfigurationTest.java
@@ -454,7 +454,7 @@ protected static class TestConfiguration {
 
         @Bean
         public Serializer eventSerializer() {
-            return XStreamSerializer.builder().build();
+            return XStreamSerializer.defaultSerializer();
         }
 
         @Bean

diff --git a/...c/main/java/org/axonframework/extensions/kafka/eventhandling/producer/KafkaPublisher.java b/...c/main/java/org/axonframework/extensions/kafka/eventhandling/producer/KafkaPublisher.java
@@ -240,8 +240,7 @@ public static class Builder<K, V> {
         @SuppressWarnings("unchecked")
         private KafkaMessageConverter<K, V> messageConverter =
                 (KafkaMessageConverter<K, V>) DefaultKafkaMessageConverter.builder()
-                                                                          .serializer(XStreamSerializer.builder()
-                                                                                                       .build())
+                                                                          .serializer(XStreamSerializer.defaultSerializer())
                                                                           .build();
         private MessageMonitor<? super EventMessage<?>> messageMonitor = NoOpMessageMonitor.instance();
         private String topic = DEFAULT_TOPIC;

diff --git a/.../org/axonframework/extensions/kafka/eventhandling/producer/KafkaPublisherBuilderTest.java b/.../org/axonframework/extensions/kafka/eventhandling/producer/KafkaPublisherBuilderTest.java
@@ -0,0 +1,22 @@
+package org.axonframework.extensions.kafka.eventhandling.producer;
+
+import org.junit.jupiter.api.*;
+import org.junit.jupiter.api.extension.*;
+import org.mockito.*;
+import org.mockito.junit.jupiter.*;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+@ExtendWith(MockitoExtension.class)
+class KafkaPublisherBuilderTest {
+
+    @Mock
+    private ProducerFactory<String, byte[]> producerFactory;
+
+    @Test
+    void testKafkaPublisherInitialisationShouldNotThrowException() {
+        assertDoesNotThrow(() -> KafkaPublisher.<String, byte[]>builder()
+                                               .producerFactory(producerFactory)
+                                               .build());
+    }
+}