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

cameronlee pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git


The following commit(s) were added to refs/heads/master by this push:
     new 043934e  SAMZA-2292: [Test improvement] Enable kafka topic deletion 
for integration test harnesses to improve test run times (#1128)
043934e is described below

commit 043934e9fc2fc1cee0debcc6ff54f146b1605e40
Author: Cameron Lee <[email protected]>
AuthorDate: Wed Aug 7 11:17:32 2019 -0700

    SAMZA-2292: [Test improvement] Enable kafka topic deletion for integration 
test harnesses to improve test run times (#1128)
---
 .../org/apache/samza/test/harness/AbstractKafkaServerTestHarness.scala   | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/samza-test/src/test/scala/org/apache/samza/test/harness/AbstractKafkaServerTestHarness.scala
 
b/samza-test/src/test/scala/org/apache/samza/test/harness/AbstractKafkaServerTestHarness.scala
index 6b11e70..ae07a9f 100644
--- 
a/samza-test/src/test/scala/org/apache/samza/test/harness/AbstractKafkaServerTestHarness.scala
+++ 
b/samza-test/src/test/scala/org/apache/samza/test/harness/AbstractKafkaServerTestHarness.scala
@@ -74,6 +74,7 @@ abstract class AbstractKafkaServerTestHarness extends 
AbstractZookeeperTestHarne
   def overridingProps: Properties = {
     val props = new Properties
     props.setProperty(KafkaConfig.NumPartitionsProp, 1.toString)
+    props.setProperty(KafkaConfig.DeleteTopicEnableProp, "true")
     props
   }
 

Reply via email to