Kstreams

Latest version: v0.18.5

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

Scan your dependencies

Page 9 of 14

Perf

- **test_utils**: replace sleep with async queue join when stopping test stream (78)

Fix

- add remove-stream function to stream_engine

Fix

- **stream**: recreate consumer when a stream instance is restarted (77)

Fix

- **teststreamclient**: check if consumer is none before creating one

Fix

- **TestStreamClient**: remove unused/unclosed mock producer (74)

Fix

- **test_clients.py**: adds end_offsets to consumer test client

Has known vulnerabilities

Previous Next