From dbdd7f662429a07dfd4dfff98401f33bab7796b8 Mon Sep 17 00:00:00 2001 From: Javier Arrieta Date: Mon, 12 Feb 2024 19:03:54 +0100 Subject: [PATCH] Propagate configuration properties to the AdminClientSettings, see #1392 (#1393) --- core/src/main/scala/tamer/Tamer.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/tamer/Tamer.scala b/core/src/main/scala/tamer/Tamer.scala index 83ad8bfa..0587efdc 100644 --- a/core/src/main/scala/tamer/Tamer.scala +++ b/core/src/main/scala/tamer/Tamer.scala @@ -326,7 +326,7 @@ object Tamer { val KafkaConfig(brokers, _, closeTimeout, _, _, _, groupId, clientId, transactionalId, properties) = config - val adminClientSettings = AdminClientSettings(closeTimeout, Map.empty) + val adminClientSettings = AdminClientSettings(closeTimeout, properties) .withBootstrapServers(brokers) val consumerSettings = ConsumerSettings(brokers) .withClientId(clientId)