root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity

MINOR: fix the way total consumed is calculated for verifiable consumer (#9143) 

Reviewers: Ron Dagostino <rdagostino@confluent.io>, Rajini Sivaram <rajinisivaram@googlemail.com>
This commit is contained in:
Sanjana Kaundinya 2020-08-16 03:15:41 -07:00 committed by GitHub
parent 70f10137f9
commit f7a4fe7c14
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tests/kafkatest/services/verifiable_consumer.py
View File

@ -97,7 +97,7 @@ class ConsumerEventHandler(object):
if tp in self.position: if tp in self.position:
self.position[tp] = max_offset + 1 self.position[tp] = max_offset + 1
logger.warn(msg) logger.warn(msg)
self.total_consumed += event["count"] self.total_consumed += event["count"]
def handle_partitions_revoked(self, event): def handle_partitions_revoked(self, event):
self.revoked_count += 1 self.revoked_count += 1