From 05a4dd85f367688f11aa9cb750268f90ec31a185 Mon Sep 17 00:00:00 2001 From: Hleb Albau Date: Mon, 2 Apr 2018 19:52:26 +0300 Subject: [PATCH] Fix kafka consumer initialization issue --- .../kotlin/fund/cyber/dump/ethereum/ApplcationConfiguration.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dumps/ethereum/src/main/kotlin/fund/cyber/dump/ethereum/ApplcationConfiguration.kt b/dumps/ethereum/src/main/kotlin/fund/cyber/dump/ethereum/ApplcationConfiguration.kt index a67a9ce6..06079eb5 100644 --- a/dumps/ethereum/src/main/kotlin/fund/cyber/dump/ethereum/ApplcationConfiguration.kt +++ b/dumps/ethereum/src/main/kotlin/fund/cyber/dump/ethereum/ApplcationConfiguration.kt @@ -34,7 +34,7 @@ import org.springframework.kafka.listener.SeekToCurrentBatchErrorHandler import org.springframework.kafka.listener.config.ContainerProperties private const val POLL_TIMEOUT = 5000L -private const val AUTO_COMMIT_INTERVAL_MS_CONFIG = 10 * 1000L +private const val AUTO_COMMIT_INTERVAL_MS_CONFIG = 10 * 1000 @Configuration class ApplicationConfiguration {