Kstreams

Latest version: v0.18.4

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

Scan your dependencies

Page 9 of 14

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

Fix

- add partitions_for_topic method to consumer test client (70)

Has known vulnerabilities

Previous Next