diff --git a/src/KafkaFlow/Clusters/ClusterManager.cs b/src/KafkaFlow/Clusters/ClusterManager.cs index 92a53b14b..0410bad6f 100644 --- a/src/KafkaFlow/Clusters/ClusterManager.cs +++ b/src/KafkaFlow/Clusters/ClusterManager.cs @@ -21,7 +21,7 @@ public ClusterManager(ILogHandler logHandler, ClusterConfiguration configuration this.lazyAdminClientBuilder = new Lazy( () => { - var adminConfig = new AdminClientConfig() + var adminConfig = new AdminClientConfig { BootstrapServers = string.Join(",", configuration.Brokers), };