feat: KstreamsRebalanceListener added as default rebalance listener

[marcosschroh]

No description provided.

[codecov]

Codecov Report

Merging #102 (acf4a35) into master (0497af8) will decrease coverage by 0.54%.
The diff coverage is 80.95%.

❗ Current head acf4a35 differs from pull request most recent head 13cd98e. Consider uploading reports for the commit 13cd98e to get more accurate results

@@            Coverage Diff             @@
##           master     #102      +/-   ##
==========================================
- Coverage   95.82%   95.29%   -0.54%     
==========================================
  Files          22       22              
  Lines         647      659      +12     
==========================================
+ Hits          620      628       +8     
- Misses         27       31       +4     

Flag	Coverage Δ
unittests	95.29% <80.95%> (-0.54%)	⬇️

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

Impacted Files	Coverage Δ
kstreams/rebalance_listener.py	76.47% <66.66%> (-23.53%)	⬇️
kstreams/__init__.py	100.00% <100.00%> (ø)
kstreams/streams.py	96.07% <100.00%> (+0.11%)	⬆️

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

[woile]

I would also like to see a "batch commit" example

[marcosschroh]

I would also like to see a "batch commit" example

Do you mean something like this?

batch = []

async def process_msg_batch(a_batch: List[...]):
    ...

@stream_engine.stream(
    topics=["local--hello-world"],
    group_id="example-group",
    enable_auto_commit=False,  # it means that we need to call commit
)
async def consume(stream):
    async for cr in stream:
        batch.append(msg)
        if len(batch) == 100:
            await process_msg_batch(batch)
            await stream.commit()
            batch = []

[woile]

Yes, something like that