Repository: kafka Updated Branches: refs/heads/0.10.0 2a9696645 -> 9ca393407
MINOR: Double timeout passed to `producer.close` in `sendAndVerifyTimestamp` We have had transient failures in this method when Jenkins is overloaded. Author: Ismael Juma <[email protected]> Reviewers: Ewen Cheslack-Postava <[email protected]> Closes #1359 from ijuma/increase-producer-close-timeout-in-test (cherry picked from commit fe0335ea1030ca61f38b343a67c78e6537d25717) Signed-off-by: Ewen Cheslack-Postava <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/9ca39340 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/9ca39340 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/9ca39340 Branch: refs/heads/0.10.0 Commit: 9ca393407ea8dfbacc5c8af388a6c815497751fd Parents: 2a96966 Author: Ismael Juma <[email protected]> Authored: Tue May 10 17:30:36 2016 -0700 Committer: Ewen Cheslack-Postava <[email protected]> Committed: Tue May 10 17:30:53 2016 -0700 ---------------------------------------------------------------------- .../test/scala/integration/kafka/api/BaseProducerSendTest.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/9ca39340/core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala ---------------------------------------------------------------------- diff --git a/core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala b/core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala index 15eeb63..9489e70 100644 --- a/core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala +++ b/core/src/test/scala/integration/kafka/api/BaseProducerSendTest.scala @@ -220,7 +220,7 @@ abstract class BaseProducerSendTest extends KafkaServerTestHarness { val record = new ProducerRecord[Array[Byte], Array[Byte]](topic, partition, baseTimestamp + i, "key".getBytes, "value".getBytes) producer.send(record, callback) } - producer.close(5000L, TimeUnit.MILLISECONDS) + producer.close(10000L, TimeUnit.MILLISECONDS) assertEquals(s"Should have offset $numRecords but only successfully sent ${callback.offset}", numRecords, callback.offset) } finally { producer.close()
