Spring boot application with KafkaListener

Application.java

@SpringBootApplication
@EnableScheduling
public class Application {

    @Autowired
    private WeatherLogService weatherLogService;

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
    
    @KafkaListener(topics = "weather-log2", groupId = "group-1", containerFactory = "kafkaListenerContainerFactory")
    public void listenGroupFoo(WeatherInfo record) {
        System.out.println("Received Message in group foo: " + record.getTemp());
        try {
            weatherLogService.saveLogs(new WeatherLog(record.getCity(), record.getLatitude(), record.getLongitude()
                    , BigDecimal.valueOf(record.getTemp()), record.getLogDate()));
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}