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

Merge pull request #1 from dato7898/master

Browse Source 
fixed json parsing
This commit is contained in:
Marley 2022-07-12 12:32:15 +03:00 committed by GitHub
commit 2bc02b2825
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
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;