Feat/di class

[woile]

Add support for pydantic as a generic in ConsumerRecord:

class Customer(BaseModel):
    id: int

@stream_engine.stream("local--kstreams")
async def stream(cr: ConsumerRecord[str, Customer]):
    assert cr.value.id == 1

This helps with autocomplete and with faster time to market, because users don't have to manually convert

[github-actions]

PR Preview Action v1.4.8
🚀 Deployed preview to https://kpn.github.io/kstreams/pr-preview/pr-260/
on branch gh-pages at 2024-12-30 17:36 UTC

[codecov]

Codecov Report

Attention: Patch coverage is 95.83333% with 1 line in your changes missing coverage. Please review.

Project coverage is 95.85%. Comparing base (e8d4b7e) to head (3c474a9).

Files with missing lines	Patch %	Lines
kstreams/middleware/udf_middleware.py	95.65%	1 Missing ⚠️

Additional details and impacted files

@@            Coverage Diff             @@
##           master     #260      +/-   ##
==========================================
+ Coverage   95.68%   95.85%   +0.17%     
==========================================
  Files          24       24              
  Lines         973      989      +16     
==========================================
+ Hits          931      948      +17     
+ Misses         42       41       -1     

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

[woile]

I think we can still merge.
There's only a regression on startup time:

test_startup_and_inject_all (0003_d75800b) - Field 'mean' has failed PercentageRegressionCheck: 14.958420546 > 10.000000000