File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
spring-kafka/src/main/java/org/springframework/kafka/core Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -202,7 +202,7 @@ public final boolean initialize() {
202202 try {
203203 synchronized (this ) {
204204 this .clusterId = adminClient .describeCluster ().clusterId ().get (this .operationTimeout ,
205- TimeUnit .MILLISECONDS );
205+ TimeUnit .SECONDS );
206206 }
207207 addOrModifyTopicsIfNeeded (adminClient , newTopics );
208208 return true ;
@@ -230,7 +230,7 @@ public final boolean initialize() {
230230 public String clusterId () {
231231 if (this .clusterId == null ) {
232232 try (AdminClient client = createAdmin ()) {
233- this .clusterId = client .describeCluster ().clusterId ().get (this .operationTimeout , TimeUnit .MILLISECONDS );
233+ this .clusterId = client .describeCluster ().clusterId ().get (this .operationTimeout , TimeUnit .SECONDS );
234234 }
235235 catch (Exception ex ) {
236236 LOGGER .error (ex , "Could not obtaine cluster info" );
You can’t perform that action at this time.
0 commit comments