Kstreams

Latest version: v0.18.5

Safety actively analyzes 640986 Python packages for vulnerabilities to keep your Python projects secure.

Scan your dependencies

Page 1 of 14

Fix

- stop properly a stream when it crashes from ExceptionMiddleware (189)

Fix

- log possible error in the typed handler wrapper (181)

Fix

- deserializer deprecation warning added. Examples with deserialization updated to middlewares (172)

Fix

- **StreamEngine**: graceful shutdown must wait for all events to be processed before Streams are stopped. Related to 162 (171)

Fix

- make sure that there is not an asyncio.Task when udf is an async generators. Middleware __repr__ added. (167)

Feat

- **TestStreamClient**: support custom classes for test consumers and producers

Has known vulnerabilities