valitydev/deanonimus
14
0
Fork 0
mirror of https://github.com/valitydev/deanonimus.git synced 2024-11-06 02:05:16 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Use default error handler

Browse Source
This commit is contained in:
Egor Cherniak 2022-09-07 11:05:40 +03:00
parent 9a988b35d0
commit 74c263db0d
No known key found for this signature in database
GPG Key ID: 26F47333B7BE4ED9
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/dev/vality/deanonimus/config/KafkaConfig.java
View File

@ -1,7 +1,7 @@
package dev.vality.deanonimus.config;
import dev.vality.deanonimus.kafka.serde.SinkEventDeserializer;
import dev.vality.kafka.common.exception.handler.ExponentialBackOffDefaultErrorHandler;
import dev.vality.kafka.common.util.ExponentialBackOffDefaultErrorHandlerFactory;
import dev.vality.machinegun.eventsink.MachineEvent;
import lombok.RequiredArgsConstructor;
import org.apache.kafka.clients.consumer.ConsumerConfig;
@ -17,7 +17,6 @@ import org.springframework.kafka.core.DefaultKafkaConsumerFactory;
import org.springframework.kafka.listener.CommonErrorHandler;
import org.springframework.kafka.listener.ConcurrentMessageListenerContainer;
import org.springframework.kafka.listener.ContainerProperties;
import org.springframework.util.backoff.ExponentialBackOff;
import java.util.Map;
@ -76,7 +75,7 @@ public class KafkaConfig {
}
public CommonErrorHandler kafkaErrorHandler() {
return new ExponentialBackOffDefaultErrorHandler(new ExponentialBackOff());
return ExponentialBackOffDefaultErrorHandlerFactory.create();
}
}