kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject kafka git commit: HOTFIX: Verifiable producer request timeout needs conversion to milliseconds
Date Fri, 03 Feb 2017 21:47:26 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.2 d952d94e5 -> 0578e2945


HOTFIX: Verifiable producer request timeout needs conversion to milliseconds

Author: Jason Gustafson <jason@confluent.io>

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

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

(cherry picked from commit 88809b9b8eb7895f3756a39ee2ad7dffd0b4d516)
Signed-off-by: Jason Gustafson <jason@confluent.io>


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

Branch: refs/heads/0.10.2
Commit: 0578e294500b220d09e46ec1c11cea42829e39f4
Parents: d952d94
Author: Jason Gustafson <jason@confluent.io>
Authored: Fri Feb 3 13:47:14 2017 -0800
Committer: Jason Gustafson <jason@confluent.io>
Committed: Fri Feb 3 13:47:23 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/0578e294/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)


Mime
View raw message