kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gwens...@apache.org
Subject kafka git commit: MINOR: Make VerifiableProducer in system tests lookup security configuration dynamically instead of at construction.
Date Mon, 11 Apr 2016 17:37:11 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk c76b6e6d9 -> 411b04a3c


MINOR: Make VerifiableProducer in system tests lookup security configuration dynamically instead
of at construction.

Author: Ewen Cheslack-Postava <me@ewencp.org>

Reviewers: Anna Povzner

Closes #1207 from ewencp/minor-dynamic-security-config-verifiable-producer


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/411b04a3
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/411b04a3
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/411b04a3

Branch: refs/heads/trunk
Commit: 411b04a3c933b5253f34342bf24f63a9473f9ab5
Parents: c76b6e6
Author: Ewen Cheslack-Postava <me@ewencp.org>
Authored: Mon Apr 11 10:37:04 2016 -0700
Committer: Gwen Shapira <cshapi@gmail.com>
Committed: Mon Apr 11 10:37:04 2016 -0700

----------------------------------------------------------------------
 tests/kafkatest/services/verifiable_producer.py | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/411b04a3/tests/kafkatest/services/verifiable_producer.py
----------------------------------------------------------------------
diff --git a/tests/kafkatest/services/verifiable_producer.py b/tests/kafkatest/services/verifiable_producer.py
index 0096a34..414da84 100644
--- a/tests/kafkatest/services/verifiable_producer.py
+++ b/tests/kafkatest/services/verifiable_producer.py
@@ -66,14 +66,17 @@ class VerifiableProducer(BackgroundThreadService):
         if self.compression_types is not None:
             assert len(self.compression_types) == num_nodes, "Specify one compression type
per node"
 
-        self.security_config = self.kafka.security_config.client_config()
-
         for node in self.nodes:
             node.version = version
         self.acked_values = []
         self.not_acked_values = []
         self.produced_count = {}
 
+
+    @property
+    def security_config(self):
+        return self.kafka.security_config.client_config()
+
     def prop_file(self, node):
         idx = self.idx(node)
         prop_file = str(self.security_config)


Mime
View raw message