You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gw...@apache.org on 2016/04/12 01:10:03 UTC
[47/50] [abbrv] kafka git commit: MINOR: Make VerifiableProducer in
system tests lookup security configuration dynamically instead of at
construction.
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/0.10.0
Commit: 411b04a3c933b5253f34342bf24f63a9473f9ab5
Parents: c76b6e6
Author: Ewen Cheslack-Postava <me...@ewencp.org>
Authored: Mon Apr 11 10:37:04 2016 -0700
Committer: Gwen Shapira <cs...@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)