[kafka] branch 2.4 updated: Actually run the delete topic command in kafka.py (#7776)

[ma...@apache.org]

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

manikumar pushed a commit to branch 2.4
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/2.4 by this push:
     new 0e14bc3  Actually run the delete topic command in kafka.py (#7776)
0e14bc3 is described below

commit 0e14bc3432c6b9656f5f2cf667c093e589988e9c
Author: David Arthur <mu...@gmail.com>
AuthorDate: Wed Dec 4 17:54:37 2019 -0500

    Actually run the delete topic command in kafka.py (#7776)
    
    Reviewed-By: Jason Gustafson <ja...@confluent.io>
---
 tests/kafkatest/services/kafka/kafka.py          | 2 ++
 tests/kafkatest/tests/core/replica_scale_test.py | 2 +-
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git a/tests/kafkatest/services/kafka/kafka.py b/tests/kafkatest/services/kafka/kafka.py
index a655b0e..e71ed7c 100644
--- a/tests/kafkatest/services/kafka/kafka.py
+++ b/tests/kafkatest/services/kafka/kafka.py
@@ -463,6 +463,8 @@ class KafkaService(KafkaPathResolverMixin, JmxMixin, Service):
             'bootstrap_servers': self.bootstrap_servers(self.security_protocol),
             'topic': topic
         }
+        self.logger.info("Running topic delete command...\n%s" % cmd)
+        node.account.ssh(cmd)
 
     def describe_topic(self, topic, node=None):
         if node is None:
diff --git a/tests/kafkatest/tests/core/replica_scale_test.py b/tests/kafkatest/tests/core/replica_scale_test.py
index e9fad39..fbbf206 100644
--- a/tests/kafkatest/tests/core/replica_scale_test.py
+++ b/tests/kafkatest/tests/core/replica_scale_test.py
@@ -128,7 +128,7 @@ class ReplicaScaleTest(Test):
             restart_times.append(broker_bounce_end_time - broker_bounce_start_time)
             self.logger.info("Time to restart %s: %d" % (node.name, broker_bounce_end_time - broker_bounce_start_time))
 
-        self.logger.info("Restart times: %s" % restart_times)
+        self.logger.info("Total time to restart: %s" % sum(restart_times))
 
         delete_start_time = time.time()
         for i in range(topic_count):