From f7a4fe7c1447a4c0c8465e6f695ad72ea145eec9 Mon Sep 17 00:00:00 2001
From: Sanjana Kaundinya <skaundinya@gmail.com>
Date: Sun, 16 Aug 2020 03:15:41 -0700
Subject: [PATCH] MINOR: fix the way total consumed is calculated for
 verifiable consumer (#9143)

Reviewers: Ron Dagostino <rdagostino@confluent.io>, Rajini Sivaram <rajinisivaram@googlemail.com>
---
 tests/kafkatest/services/verifiable_consumer.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tests/kafkatest/services/verifiable_consumer.py b/tests/kafkatest/services/verifiable_consumer.py
index 85083ba0d4f..433823bbab1 100644
--- a/tests/kafkatest/services/verifiable_consumer.py
+++ b/tests/kafkatest/services/verifiable_consumer.py
@@ -97,7 +97,7 @@ class ConsumerEventHandler(object):
                     if tp in self.position:
                         self.position[tp] = max_offset + 1
                     logger.warn(msg)
-            self.total_consumed += event["count"]
+        self.total_consumed += event["count"]
 
     def handle_partitions_revoked(self, event):
         self.revoked_count += 1