Yadciel/Kafka-Tutorial
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fixed json parsing

Browse Source
This commit is contained in:
david 2022-07-12 15:27:05 +06:00
parent aed0f06587
commit c424f15289
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
app/src/main/java/org/javadev/kafkaexample/config/KafkaConsumerConfig.java
View File

@ -11,6 +11,8 @@ import org.springframework.kafka.config.KafkaListenerContainerFactory;
import org.springframework.kafka.core.ConsumerFactory; import org.springframework.kafka.core.ConsumerFactory;
import org.springframework.kafka.core.DefaultKafkaConsumerFactory; import org.springframework.kafka.core.DefaultKafkaConsumerFactory;
import org.springframework.kafka.listener.ConcurrentMessageListenerContainer; import org.springframework.kafka.listener.ConcurrentMessageListenerContainer;
import org.springframework.kafka.support.converter.JsonMessageConverter;
import org.springframework.kafka.support.converter.RecordMessageConverter;
import org.springframework.kafka.support.serializer.JsonDeserializer; import org.springframework.kafka.support.serializer.JsonDeserializer;
import java.util.HashMap; import java.util.HashMap;
@ -47,4 +49,9 @@ public class KafkaConsumerConfig {
return factory; return factory;
} }
@Bean
public RecordMessageConverter converter() {
return new JsonMessageConverter();
}
} // The End of Class; } // The End of Class;