You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2017/10/27 23:08:23 UTC
kafka git commit: One minor fix on the TransactionsTest.scala
Repository: kafka
Updated Branches:
refs/heads/0.11.0 5bbfd614d -> c9d1fc130
One minor fix on the TransactionsTest.scala
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/c9d1fc13
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/c9d1fc13
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/c9d1fc13
Branch: refs/heads/0.11.0
Commit: c9d1fc13085a0b49f92607e128167f95285ff875
Parents: 5bbfd61
Author: Guozhang Wang <wa...@gmail.com>
Authored: Fri Oct 27 16:08:08 2017 -0700
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Fri Oct 27 16:08:08 2017 -0700
----------------------------------------------------------------------
core/src/test/scala/integration/kafka/api/TransactionsTest.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/c9d1fc13/core/src/test/scala/integration/kafka/api/TransactionsTest.scala
----------------------------------------------------------------------
diff --git a/core/src/test/scala/integration/kafka/api/TransactionsTest.scala b/core/src/test/scala/integration/kafka/api/TransactionsTest.scala
index b04782f..65b8f89 100644
--- a/core/src/test/scala/integration/kafka/api/TransactionsTest.scala
+++ b/core/src/test/scala/integration/kafka/api/TransactionsTest.scala
@@ -464,7 +464,7 @@ class TransactionsTest extends KafkaServerTestHarness {
// The first message and hence the first AddPartitions request should be successfully sent.
val firstMessageResult = producer.send(TestUtils.producerRecordWithExpectedTransactionStatus(topic1, "1", "1", willBeCommitted = false)).get()
- assertTrue(firstMessageResult.hasOffset)
+ assertTrue(firstMessageResult.offset() != -1)
// Wait for the expiration cycle to kick in.
Thread.sleep(600)