Optimize Kafka Client in Kafka Connector

[sanketsudake]

Signed-off-by: Sanket Sudake sanketsudake@gmail.com

Description

• Set message lag count when subscribe created first time
• Create single Kafka Client for all Kafka producers and consumers

Which issue(s) this PR fixes:

Fixes #

Testing

Checklist:

• I ran tests as well as code linting locally to verify my changes.
• I have done manual verification of my changes, changes working as expected.
• I have added new tests to cover my changes.
• My changes follow contributing guidelines of Fission.
• I have signed all of my commits.

[codecov]

Codecov Report

Merging #2630 (667ffa0) into main (1e0641d) will not change coverage.
The diff coverage is n/a.

@@           Coverage Diff           @@
##             main    #2630   +/-   ##
=======================================
  Coverage   19.60%   19.60%           
=======================================
  Files          63       63           
  Lines        7131     7131           
=======================================
  Hits         1398     1398           
  Misses       5629     5629           
  Partials      104      104           

Flag	Coverage Δ
unittests	19.60% <ø> (ø)

Flags with carried forward coverage won't be shown. Click here to find out more.

📣 We’re building smart automated test selection to slash your CI/CD build times. Learn more