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
index d917bbaeb4..afcd992035 100644
--- 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());
       }