Repository: kafka Updated Branches: refs/heads/trunk 75c7abd82 -> 78e7f87db
MINOR: fix verifiable consumer assertion Author: Jason Gustafson <[email protected]> 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 <[email protected]> Authored: Mon Nov 30 11:01:54 2015 -0800 Committer: Guozhang Wang <[email protected]> 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):
