[metron] branch feature/METRON-2088-support-hdp-3.1 updated: METRON-2252 PcapTopologyIntegrationTest Intermittent Failures (nickwallen) closes apache/metron#1508

[nickallen]

This is an automated email from the ASF dual-hosted git repository.

nickallen pushed a commit to branch feature/METRON-2088-support-hdp-3.1
in repository https://gitbox.apache.org/repos/asf/metron.git


The following commit(s) were added to 
refs/heads/feature/METRON-2088-support-hdp-3.1 by this push:
     new b25f9a5  METRON-2252 PcapTopologyIntegrationTest Intermittent Failures 
(nickwallen) closes apache/metron#1508
b25f9a5 is described below

commit b25f9a52d3186d72d1e3000f1e608e57b294c10a
Author: nickwallen <n...@nickallen.org>
AuthorDate: Thu Sep 12 09:57:22 2019 -0400

    METRON-2252 PcapTopologyIntegrationTest Intermittent Failures (nickwallen) 
closes apache/metron#1508
---
 .../src/main/java/org/apache/metron/integration/utils/KafkaUtil.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/metron-platform/metron-integration-test/src/main/java/org/apache/metron/integration/utils/KafkaUtil.java
 
b/metron-platform/metron-integration-test/src/main/java/org/apache/metron/integration/utils/KafkaUtil.java
index 0292808..f9271aa 100644
--- 
a/metron-platform/metron-integration-test/src/main/java/org/apache/metron/integration/utils/KafkaUtil.java
+++ 
b/metron-platform/metron-integration-test/src/main/java/org/apache/metron/integration/utils/KafkaUtil.java
@@ -36,6 +36,7 @@ public class KafkaUtil {
                 Thread.sleep(sleepBetween);
             }
         }
+        // wait for all messages to be sent
+        producer.flush();
     }
-
 }