diff --git a/psc-flink/src/test/java/com/pinterest/flink/streaming/connectors/psc/FlinkPscProducerITCase.java b/psc-flink/src/test/java/com/pinterest/flink/streaming/connectors/psc/FlinkPscProducerITCase.java
index 17defec..eb82a57 100644
--- a/psc-flink/src/test/java/com/pinterest/flink/streaming/connectors/psc/FlinkPscProducerITCase.java
+++ b/psc-flink/src/test/java/com/pinterest/flink/streaming/connectors/psc/FlinkPscProducerITCase.java
@@ -205,6 +205,7 @@ public void testFlinkPscProducerFailBeforeNotify() throws Exception {
 
         assertExactlyOnceForTopicUri(createProperties(), topicUri, 0, Arrays.asList(42, 43));
 
+        Thread.sleep(5000); // wait for broker to start up before deleting topic
         deleteTestTopic(topic);
         checkProducerLeak();
     }
diff --git a/psc/src/test/resources/log4j2-test.xml b/psc/src/test/resources/log4j2-test.xml
index 116575d..9e25415 100644
--- a/psc/src/test/resources/log4j2-test.xml
+++ b/psc/src/test/resources/log4j2-test.xml
@@ -12,7 +12,7 @@
     </Appenders>
 
     <Loggers>
-        <AsyncRoot level="info" includeLocation="true">
+        <AsyncRoot level="error" includeLocation="true">
             <AppenderRef ref="console"/>
         </AsyncRoot>
     </Loggers>