You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
When specifying the generic types in ConsumerRecord, e.g. ConsumerRecord[Any, Any] in the stream function signature, the ANNOTATIONS_TO_PARAMS mapping fails to map the consumerrecord to the parameter.
Describe the bug
When specifying the generic types in ConsumerRecord, e.g.
ConsumerRecord[Any, Any]
in the stream function signature, theANNOTATIONS_TO_PARAMS
mapping fails to map the consumerrecord to the parameter.kstreams/kstreams/middleware/udf_middleware.py
Line 28 in 5e85da3
To Reproduce
Create a UDF style stream function with
cr: ConsumerRecord[Any, Any]
Expected behavior
It should just work like it does without specifying the generics.
The text was updated successfully, but these errors were encountered: