diff --git a/pom.xml b/pom.xml index 04b2a8e..c524831 100644 --- a/pom.xml +++ b/pom.xml @@ -13,7 +13,7 @@ com.rbkmoney service-parent-pom - 1.2.2 + 1.2.7 @@ -103,6 +103,7 @@ com.rbkmoney kafka-common-lib + 0.1.8 com.rbkmoney diff --git a/src/main/java/com/rbkmoney/hooker/configuration/KafkaConfig.java b/src/main/java/com/rbkmoney/hooker/configuration/KafkaConfig.java index 991997c..654a84a 100644 --- a/src/main/java/com/rbkmoney/hooker/configuration/KafkaConfig.java +++ b/src/main/java/com/rbkmoney/hooker/configuration/KafkaConfig.java @@ -104,7 +104,6 @@ public class KafkaConfig { new ConcurrentKafkaListenerContainerFactory<>(); factory.setConsumerFactory(consumerFactory); factory.setBatchListener(true); - factory.getContainerProperties().setAckOnError(false); factory.getContainerProperties().setAckMode(ContainerProperties.AckMode.MANUAL); factory.setBatchErrorHandler(kafkaErrorHandler()); factory.setConcurrency(invoicingConcurrency); @@ -120,7 +119,6 @@ public class KafkaConfig { new ConcurrentKafkaListenerContainerFactory<>(); factory.setConsumerFactory(consumerFactory); factory.setBatchListener(false); - factory.getContainerProperties().setAckOnError(false); factory.getContainerProperties().setAckMode(ContainerProperties.AckMode.MANUAL); factory.setErrorHandler(new SeekToCurrentErrorHandler()); factory.setConcurrency(customerConcurrency); diff --git a/src/main/java/com/rbkmoney/hooker/service/MessageProcessor.java b/src/main/java/com/rbkmoney/hooker/service/MessageProcessor.java index a3ca53d..cacdba6 100644 --- a/src/main/java/com/rbkmoney/hooker/service/MessageProcessor.java +++ b/src/main/java/com/rbkmoney/hooker/service/MessageProcessor.java @@ -111,8 +111,8 @@ public class MessageProcessor implements Run } private void updateAvailability(Queue queue) { - double rate = faultDetector.getRate(queue.getHook().getId()); - hookDao.updateAvailability(queue.getHook().getId(), rate); - log.info("Hook {} availability has been updated to {}", queue.getHook().getId(), rate); + //double rate = faultDetector.getRate(queue.getHook().getId()); + //hookDao.updateAvailability(queue.getHook().getId(), rate); + //log.info("Hook {} availability has been updated to {}", queue.getHook().getId(), rate); } }