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
}