Handling consumer offset

Author: javaHelper

07-consuming-with-consumer-groups/pom.xml

@@ -5,7 +5,7 @@
 	<parent>
 		<groupId>org.springframework.boot</groupId>
 		<artifactId>spring-boot-starter-parent</artifactId>
-		<version>2.7.5</version>
+		<version>3.3.1</version>
 		<relativePath/> <!-- lookup parent from repository -->
 	</parent>
 	<groupId>com.course.kafka</groupId>

07-consuming-with-consumer-groups/src/main/java/com/course/kafka/scheduler/CommodityScheduler.java

@@ -11,6 +11,7 @@
 import org.springframework.web.client.RestTemplate;
 
 import java.util.List;
+import java.util.Objects;
 
 @Service
 public class CommodityScheduler {
@@ -26,7 +27,7 @@ public void fetchCommodities(){
                 new ParameterizedTypeReference<List<Commodity>>() {
                 }).getBody();
 
-        commodities.forEach(commodity -> {
+        Objects.requireNonNull(commodities).forEach(commodity -> {
             try {
                 producer.sendMessage(commodity);
             } catch (JsonProcessingException e) {