chore: kafka batching

[fracasula]

Description

Making sure that batching on Kafka works as expected.

Notion Ticket

< Notion Link >

Security

• The code changed/added as part of this pull request won't create any security issues with how the software is being used.

[codecov]

Codecov Report

Patch coverage: 74.60% and project coverage change: +0.06 🎉

Comparison is base (d7ac3a8) 52.28% compared to head (f1e3e94) 52.35%.

Additional details and impacted files

@@            Coverage Diff             @@
##           master    #3151      +/-   ##
==========================================
+ Coverage   52.28%   52.35%   +0.06%     
==========================================
  Files         321      321              
  Lines       52789    52809      +20     
==========================================
+ Hits        27602    27646      +44     
+ Misses      23527    23512      -15     
+ Partials     1660     1651       -9     

Impacted Files	Coverage Δ
runner/runner.go	69.88% <42.10%> (ø)
services/streammanager/kafka/kafkamanager.go	76.81% <82.14%> (+0.06%)	⬆️
regulation-worker/cmd/main.go	71.95% <100.00%> (ø)
services/streammanager/kafka/client/producer.go	84.03% <100.00%> (+4.21%)	⬆️

... and 7 files with indirect coverage changes

Help us with your feedback. Take ten seconds to tell us how you rate us. Have a feature suggestion? Share it here.

☔ View full report in Codecov by Sentry.
📢 Do you have feedback about the report comment? Let us know in this issue.

[atzoum]

Question: does batching work in combination with AVRO Schema Lists and/or multiple topic support? This is not evident by looking here, where it seems like the process method is performing more steps than its batch counterpart. Maybe batch is called with events that have already been processed in a previous step?

@utsabc @koladilip

[atzoum]

I think I can answer that question myself... events are first transformed at processor, then batched at router!