diff --git a/CHANGELOG.md b/CHANGELOG.md index efb53d2..84e2dab 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -5,6 +5,10 @@ All notable changes to this project will be documented in this file. The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/), and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html). +## [0.25.1] - 2023-10-30 +### Added +- Setting METADATA_MAX_AGE_CONFIG to two minutes for producer + ## [0.25.0] - 2023-08-09 ### Added diff --git a/gradle.properties b/gradle.properties index 37a3805..b73a05f 100644 --- a/gradle.properties +++ b/gradle.properties @@ -1 +1 @@ -version=0.25.0 \ No newline at end of file +version=0.25.1 diff --git a/tw-tkms-starter/src/main/java/com/transferwise/kafka/tkms/config/TkmsKafkaProducerProvider.java b/tw-tkms-starter/src/main/java/com/transferwise/kafka/tkms/config/TkmsKafkaProducerProvider.java index e9de4fc..2ce4f24 100644 --- a/tw-tkms-starter/src/main/java/com/transferwise/kafka/tkms/config/TkmsKafkaProducerProvider.java +++ b/tw-tkms-starter/src/main/java/com/transferwise/kafka/tkms/config/TkmsKafkaProducerProvider.java @@ -44,6 +44,7 @@ public KafkaProducer getKafkaProducer(int shard) { configs.put(ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG, "5000"); configs.put(ProducerConfig.DELIVERY_TIMEOUT_MS_CONFIG, "10000"); configs.put(ProducerConfig.LINGER_MS_CONFIG, "5"); + configs.put(ProducerConfig.METADATA_MAX_AGE_CONFIG, "120000"); configs.putAll(tkmsProperties.getKafka());