Repository: kafka
Updated Branches:
  refs/heads/trunk 7ebc5da60 -> 88809b9b8


HOTFIX: Verifiable producer request timeout needs conversion to milliseconds

Author: Jason Gustafson <ja...@confluent.io>

Reviewers: Ewen Cheslack-Postava <e...@confluent.io>

Closes #2494 from hachikuji/hotfix-verifiable-producer-request-timeout


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

Branch: refs/heads/trunk
Commit: 88809b9b8eb7895f3756a39ee2ad7dffd0b4d516
Parents: 7ebc5da
Author: Jason Gustafson <ja...@confluent.io>
Authored: Fri Feb 3 13:47:14 2017 -0800
Committer: Jason Gustafson <ja...@confluent.io>
Committed: Fri Feb 3 13:47:14 2017 -0800

----------------------------------------------------------------------
 tests/kafkatest/services/verifiable_producer.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/88809b9b/tests/kafkatest/services/verifiable_producer.py
----------------------------------------------------------------------
diff --git a/tests/kafkatest/services/verifiable_producer.py 
b/tests/kafkatest/services/verifiable_producer.py
index bc327c7..5f39df2 100644
--- a/tests/kafkatest/services/verifiable_producer.py
+++ b/tests/kafkatest/services/verifiable_producer.py
@@ -112,7 +112,7 @@ class VerifiableProducer(KafkaPathResolverMixin, 
BackgroundThreadService):
             self.logger.info("VerifiableProducer (index = %d) will use acks = 
%s", idx, self.acks)
             producer_prop_file += "\nacks=%s\n" % self.acks
 
-        producer_prop_file += "\nrequest.timeout.ms=%d\n" % 
self.request_timeout_sec
+        producer_prop_file += "\nrequest.timeout.ms=%d\n" % 
(self.request_timeout_sec * 1000)
         self.logger.info("verifiable_producer.properties:")
         self.logger.info(producer_prop_file)
         node.account.create_file(VerifiableProducer.CONFIG_FILE, 
producer_prop_file)

Reply via email to