diff --git a/app/src/main/java/org/javadev/kafkaexample/config/KafkaConsumerConfig.java b/app/src/main/java/org/javadev/kafkaexample/config/KafkaConsumerConfig.java index 259940f..21711f9 100644 --- a/app/src/main/java/org/javadev/kafkaexample/config/KafkaConsumerConfig.java +++ b/app/src/main/java/org/javadev/kafkaexample/config/KafkaConsumerConfig.java @@ -37,7 +37,7 @@ public ConsumerFactory consumerFactory(){ return new DefaultKafkaConsumerFactory<>( consumerConfig(), new StringDeserializer(), - new JsonDeserializer<>() + jsonDeserializer ); } diff --git a/license b/license new file mode 100644 index 0000000..8b13789 --- /dev/null +++ b/license @@ -0,0 +1 @@ +