removed java config and using default container factory

sb-kafka-consumer/src/main/java/org/purbarun/kafka/SbKafkaConsumerApplication.java

@@ -22,30 +22,4 @@ public class SbKafkaConsumerApplication {
 	public static void main(String[] args) {
 		SpringApplication.run(SbKafkaConsumerApplication.class, args);
 	}
-
-	@Bean
-	ConsumerFactory<String, OrderMessage> consumerFactory() {
-
-		// Creating a map of string-object type
-		Map<String, Object> config = new HashMap<>();
-
-		// Adding the Configuration
-		config.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "127.0.0.1:9092");
-		config.put(ConsumerConfig.GROUP_ID_CONFIG, "NEW_ORDER_group");
-		config.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
-		config.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, JsonDeserializer.class);
-
-		// Returning message in JSON format
-		return new DefaultKafkaConsumerFactory<>(config, new StringDeserializer(),
-				new JsonDeserializer<>(OrderMessage.class));
-	}
-
-	// Creating a Listener
-	@Bean
-	ConcurrentKafkaListenerContainerFactory<String, OrderMessage> orderListener() {
-		ConcurrentKafkaListenerContainerFactory<String, OrderMessage> factory = new ConcurrentKafkaListenerContainerFactory<>();
-		factory.setConsumerFactory(consumerFactory());
-		return factory;
-	}
-
 }

sb-kafka-consumer/src/main/java/org/purbarun/kafka/service/KafkaConsumer.java

@@ -10,7 +10,7 @@
 
 @Service
 public class KafkaConsumer {
-	@KafkaListener(groupId = "NEW_ORDER_group", topics = "NEW_ORDER",containerFactory = "orderListener")
+	@KafkaListener(groupId = "NEW_ORDER_group", topics = "NEW_ORDER")
 	public void consume(OrderMessage orderMessage,Acknowledgment acknowledgment) {
 		System.out.println(orderMessage);
 		acknowledgment.acknowledge();