Kstreams

Latest version: v0.18.4

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

Scan your dependencies

Page 1 of 14

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

Fix

- mypy updated from version 0.9 to 1.8.0. Some typing fixed. Closes 159 (165)

Has known vulnerabilities