From b250f404114101e6f9c7ac6df0cdcd7b354c8911 Mon Sep 17 00:00:00 2001 From: Maheshkumar P <67100964+Maheshkumar-novice@users.noreply.github.com> Date: Thu, 3 Oct 2024 16:21:28 +0530 Subject: [PATCH] Fix typo in verifiable_client.py --- src/confluent_kafka/kafkatest/verifiable_client.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/confluent_kafka/kafkatest/verifiable_client.py b/src/confluent_kafka/kafkatest/verifiable_client.py index 56d4383e3..f83c69a9c 100644 --- a/src/confluent_kafka/kafkatest/verifiable_client.py +++ b/src/confluent_kafka/kafkatest/verifiable_client.py @@ -59,7 +59,7 @@ def err(self, s, term=False): sys.exit(1) def send(self, d): - """ Send dict as JSON to stdout for consumtion by kafkatest handler """ + """ Send dict as JSON to stdout for consumption by kafkatest handler. """ d['_time'] = str(datetime.datetime.now()) self.dbg('SEND: %s' % json.dumps(d)) sys.stdout.write('%s\n' % json.dumps(d))