kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR: fix verifiable consumer assertion
Date Mon, 30 Nov 2015 19:01:59 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 75c7abd82 -> 78e7f87db


MINOR: fix verifiable consumer assertion

Author: Jason Gustafson <jason@confluent.io>

Reviewers: Guozhang Wang

Closes #597 from hachikuji/fix-verifiable-consumer-assertion


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

Branch: refs/heads/trunk
Commit: 78e7f87db8be3b1eae59752e8c9ceb0b8c064a96
Parents: 75c7abd
Author: Jason Gustafson <jason@confluent.io>
Authored: Mon Nov 30 11:01:54 2015 -0800
Committer: Guozhang Wang <wangguoz@gmail.com>
Committed: Mon Nov 30 11:01:54 2015 -0800

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


http://git-wip-us.apache.org/repos/asf/kafka/blob/78e7f87d/tests/kafkatest/services/verifiable_consumer.py
----------------------------------------------------------------------
diff --git a/tests/kafkatest/services/verifiable_consumer.py b/tests/kafkatest/services/verifiable_consumer.py
index eec46d7..23b0586 100644
--- a/tests/kafkatest/services/verifiable_consumer.py
+++ b/tests/kafkatest/services/verifiable_consumer.py
@@ -56,7 +56,7 @@ class ConsumerEventHandler(object):
                 tp = TopicPartition(topic, partition)
                 offset = offset_commit["offset"]
                 assert tp in self.assignment, "Committed offsets for a partition not assigned"
-                assert self.position[tp] <= offset, "The committed offset was greater
than the current position"
+                assert self.position[tp] >= offset, "The committed offset was greater
than the current position"
                 self.committed[tp] = offset
 
     def handle_records_consumed(self, event):


Mime
View raw message