From d19b7ac8410db7d2de1bb4e437aa7de7e7960832 Mon Sep 17 00:00:00 2001
From: HHans09 <heena.hans@molecula.com>
Date: Wed, 21 Sep 2022 13:46:30 -0400
Subject: [PATCH] UPdated the code to remove declared but unused variables -
 committedOffsets, stv & iv

---
 idk/kafka/source.go | 7 +------
 1 file changed, 1 insertion(+), 6 deletions(-)

diff --git a/idk/kafka/source.go b/idk/kafka/source.go
index 1e00398e5..e0a9ec096 100644
--- a/idk/kafka/source.go
+++ b/idk/kafka/source.go
@@ -232,11 +232,7 @@ func (r *Record) Commit(ctx context.Context) error {
 		s = *x.Topic
 		p = x.Partition
 	}
-	committedOffsets, err := r.src.CommitMessages(r.src.highmarks)
-	if err != nil {
-		return errors.Wrap(err, "failed to commit messages")
-	}
-
+	
 	r.src.spool = remaining
 	r.src.spoolBase = idx
 	return nil
@@ -302,7 +298,6 @@ func (s *Source) Open() error {
 			return err
 		}
 		s.Log.Debugf(buf.String())
-		stv, iv := confluent.LibraryVersion()
 
 	}
 	cl, err := confluent.NewConsumer(s.ConfigMap)