build(deps): bump aiokafka from 0.8.1 to 0.10.0. ruff added in order to replace isort, flake8 and black

kstreams/clients.py

@@ -16,7 +16,9 @@
         self.config = kwargs
 
         if key_deserializer is None:
-            key_deserializer = lambda k: None if k is None else k.decode()
+            def key_deserializer(key):
+                if key is not None:
+                    return key.decode()
 
         super().__init__(*args, key_deserializer=key_deserializer, **self.config)
 
@@ -31,7 +33,9 @@
         self.config = kwargs
 
         if key_serializer is None:
-            key_serializer = lambda k: None if k is None else k.encode("utf-8")
+            def key_serializer(key):
+                if key is not None:
+                    return key.encode("utf-8")
 
         super().__init__(*args, key_serializer=key_serializer, **self.config)
 

kstreams/engine.py

@@ -12,7 +12,7 @@
 from .prometheus.monitor import PrometheusMonitor
 from .rebalance_listener import MetricsRebalanceListener, RebalanceListener
 from .serializers import Deserializer, Serializer
-from .streams import Stream, StreamFunc, stream
+from .streams import Stream, StreamFunc, stream as stream_func
 from .types import Headers
 from .utils import encode_headers
 
@@ -216,7 +216,7 @@ def stream(
         **kwargs,
     ) -> Callable[[StreamFunc], Stream]:
         def decorator(func: StreamFunc) -> Stream:
-            stream_from_func = stream(
+            stream_from_func = stream_func(
                 topics,
                 name=name,
                 deserializer=deserializer,