diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java b/streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java
index b435ceb41174f..ab23af0316c78 100644
--- a/streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java
@@ -287,7 +287,7 @@ public boolean conditionMet() {
                     }
 
                 }
-            }, 30000, "waiting for metadata, store and value to be non null");
+            }, 120000, "waiting for metadata, store and value to be non null");
         }
     }
 
@@ -319,7 +319,7 @@ public boolean conditionMet() {
                     }
 
                 }
-            }, 30000, "waiting for metadata, store and value to be non null");
+            }, 120000, "waiting for metadata, store and value to be non null");
         }
     }
 
@@ -850,7 +850,7 @@ private void waitUntilAtLeastNumRecordProcessed(final String topic, final int nu
             config,
             topic,
             numRecs,
-            60 * 1000);
+            120 * 1000);
     }
 
     private Set<KeyValue<String, Long>> fetch(final ReadOnlyWindowStore<String, Long> store,
@@ -909,7 +909,7 @@ public void run() {
             final Properties producerConfig = new Properties();
             producerConfig.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, CLUSTER.bootstrapServers());
             producerConfig.put(ProducerConfig.ACKS_CONFIG, "all");
-            producerConfig.put(ProducerConfig.RETRIES_CONFIG, 0);
+            producerConfig.put(ProducerConfig.RETRIES_CONFIG, 10);
             producerConfig.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
             producerConfig.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);