[FSTORE-800] Increase timeout to create kafka topics (#1405)

logicalclocks · May 22, 2023 · b231040 · b231040
1 parent afead64
commit b231040
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/hopsworks-common/src/main/java/io/hops/hopsworks/common/kafka/KafkaController.java b/hopsworks-common/src/main/java/io/hops/hopsworks/common/kafka/KafkaController.java
@@ -201,7 +201,7 @@ public ProjectTopics createTopicInProject(Project project, TopicDTO topicDto) th
 
     // create the topic in kafka
     try {
-      if (createTopicInKafka(topicDto).get(3000, TimeUnit.MILLISECONDS) == null) {
+      if (createTopicInKafka(topicDto).get(6000, TimeUnit.MILLISECONDS) == null) {
         throw new KafkaException(RESTCodes.KafkaErrorCode.TOPIC_ALREADY_EXISTS_IN_ZOOKEEPER, Level.INFO,
           "topic name: " + topicDto.getName());
       }