MODRS-194 Updating dependencies for Quesnelia

folio-org · Mar 14, 2024 · 5b138a5 · 5b138a5
1 parent f916e27
commit 5b138a5
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/main/java/org/folio/rs/config/KafkaConfiguration.java b/src/main/java/org/folio/rs/config/KafkaConfiguration.java
@@ -35,14 +35,14 @@ public ConcurrentKafkaListenerContainerFactory<String, DomainEvent> kafkaListene
     var factory = new ConcurrentKafkaListenerContainerFactory<String, DomainEvent>();
     factory.setBatchListener(true);
     factory.setConsumerFactory(jsonNodeConsumerFactory());
-    factory.setCommonErrorHandler(new DefaultErrorHandler((exception, data) ->
-      log.error("Error in process with Exception {} and the record is {}", exception, data)));
+    factory.setCommonErrorHandler(new DefaultErrorHandler((exception, data) -> log.error(
+      "Error in process with Exception {} and the record is {}", exception, data)));
     return factory;
   }
 
   private ConsumerFactory<String, DomainEvent> jsonNodeConsumerFactory() {
     var deserializer = new JsonDeserializer<>(DomainEvent.class);
-    Map<String, Object> config = new HashMap<>(kafkaProperties.buildConsumerProperties());
+    Map<String, Object> config = new HashMap<>(kafkaProperties.buildConsumerProperties(null));
     config.put(KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
     config.put(VALUE_DESERIALIZER_CLASS_CONFIG, deserializer);
     return new DefaultKafkaConsumerFactory<>(config, new StringDeserializer(), deserializer);