diff --git a/kafka-native-serialization/src/main/java/com/example/kafkanativeserialization/MyJsonSerializer.java b/kafka-native-serialization/src/main/java/com/example/kafkanativeserialization/MyJsonSerializer.java
deleted file mode 100644
index b5a4e80..0000000
--- a/kafka-native-serialization/src/main/java/com/example/kafkanativeserialization/MyJsonSerializer.java
+++ /dev/null
@@ -1,19 +0,0 @@
-package com.example.kafkanativeserialization;
-
-import org.apache.kafka.common.header.Headers;
-import org.springframework.kafka.support.serializer.JsonSerializer;
-import org.springframework.lang.Nullable;
-
-public class MyJsonSerializer extends JsonSerializer<Object> {
-
-	@Override
-	@Nullable
-	public byte[] serialize(String topic, Headers headers, @Nullable Object data) {
-		return super.serialize(topic, headers, data);
-	}
-	@Override
-	@Nullable
-	public byte[] serialize(String topic, @Nullable Object data) {
-		return super.serialize(topic, data);
-	}
-}
diff --git a/kafka-native-serialization/src/main/resources/application.yml b/kafka-native-serialization/src/main/resources/application.yml
index 830fe2b..f935232 100644
--- a/kafka-native-serialization/src/main/resources/application.yml
+++ b/kafka-native-serialization/src/main/resources/application.yml
@@ -14,4 +14,4 @@ spring.cloud:
         process-out-0:
           producer:
             configuration:
-              value.serializer: com.example.kafkanativeserialization.MyJsonSerializer
\ No newline at end of file
+              value.serializer: org.springframework.kafka.support.serializer.JsonSerializer
\ No newline at end of file
diff --git a/kafka-native-serialization/src/test/java/com/example/kafkanativeserialization/KafkaNativeSerializationApplicationTests.java b/kafka-native-serialization/src/test/java/com/example/kafkanativeserialization/KafkaNativeSerializationApplicationTests.java
index 436ff63..2e00b64 100644
--- a/kafka-native-serialization/src/test/java/com/example/kafkanativeserialization/KafkaNativeSerializationApplicationTests.java
+++ b/kafka-native-serialization/src/test/java/com/example/kafkanativeserialization/KafkaNativeSerializationApplicationTests.java
@@ -54,7 +54,7 @@ public class KafkaNativeSerializationApplicationTests {
 
 		Consumer<byte[], Person> consumer = cf.createConsumer();
 		consumer.subscribe(Collections.singleton(OUTPUT_TOPIC));
-		ConsumerRecords<byte[], Person> records = consumer.poll(Duration.ofSeconds(5));
+		ConsumerRecords<byte[], Person> records = consumer.poll(Duration.ofSeconds(10));
 		consumer.commitSync();
 
 		assertThat(records.count()).isEqualTo(1);