Propagate configuration properties to the AdminClientSettings, see #1392

(#1393)
laserdisc-io · Feb 12, 2024 · dbdd7f6 · dbdd7f6
1 parent 87a92ea
commit dbdd7f6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)