From 1fa51417dc4c35737c23b30f1eed976b036ff6d1 Mon Sep 17 00:00:00 2001
From: Rajaditya Chauhan <rajchauh@redhat.com>
Date: Wed, 3 Jan 2024 15:30:31 +0530
Subject: [PATCH] Fixing typo

---
 opl/skip_to_end.py | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/opl/skip_to_end.py b/opl/skip_to_end.py
index d219f2e..2c6b7cf 100755
--- a/opl/skip_to_end.py
+++ b/opl/skip_to_end.py
@@ -14,7 +14,7 @@
 def create_consumer(args):
     # Common parameters for both cases
     common_params = {
-        "bootstrap_servers": args.kafka_hosts,
+        "bootstrap_servers": args.kafka_host,
         "auto_offset_reset": "latest",
         "enable_auto_commit": True,
         "group_id": args.kafka_group,
@@ -26,7 +26,7 @@ def create_consumer(args):
     # Kafka consumer creation: SASL or noauth
     if args.kafka_username != "" and args.kafka_password != "":
         logging.info(
-            f"Creating SASL password-protected Kafka consumer for {args.kafka_hosts} in group {args.kafka_group} with timeout {args.kafka_timeout} ms topic {args.kafka_topic}"
+            f"Creating SASL password-protected Kafka consumer for {args.kafka_host} in group {args.kafka_group} with timeout {args.kafka_timeout} ms topic {args.kafka_topic}"
         )
         sasl_params = {
             "security_protocol": "SASL_SSL",
@@ -37,7 +37,7 @@ def create_consumer(args):
         consumer = KafkaConsumer([args.kafka_topic], **common_params, **sasl_params)
     else:
         logging.info(
-            f"Creating passwordless producer for for {args.kafka_hosts} in group {args.kafka_group} with timeout {args.kafka_timeout} ms topic {args.kafka_topic}"
+            f"Creating passwordless producer for for {args.kafka_host} in group {args.kafka_group} with timeout {args.kafka_timeout} ms topic {args.kafka_topic}"
         )
         consumer = KafkaConsumer([args.kafka_topic], **common_params)
     return consumer