Skip to content

Commit dbdd7f6

Browse files
Propagate configuration properties to the AdminClientSettings, see #1392 (#1393)
1 parent 87a92ea commit dbdd7f6

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/scala/tamer/Tamer.scala

+1-1
Original file line numberDiff line numberDiff line change
@@ -326,7 +326,7 @@ object Tamer {
326326

327327
val KafkaConfig(brokers, _, closeTimeout, _, _, _, groupId, clientId, transactionalId, properties) = config
328328

329-
val adminClientSettings = AdminClientSettings(closeTimeout, Map.empty)
329+
val adminClientSettings = AdminClientSettings(closeTimeout, properties)
330330
.withBootstrapServers(brokers)
331331
val consumerSettings = ConsumerSettings(brokers)
332332
.withClientId(clientId)

0 commit comments

Comments
 (0)