Kstreams

Latest version: v0.18.4

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

Scan your dependencies

Page 3 of 14

Fix

- **Stream**: handle errors.ConsumerStoppedError exception for the new consumtion way (150)

Feat

- **TestStreamClient**: add ability to create extra topics before the test cycle starts (149)

Feat

- getmany added to Stream. Closes 128 (147)

Fix

- **typing**: StreamFunc type to match the udf signature. (142)

Feat

- first steps to add dependency injection. Inspect udf coroutines in order to inject different args on it (141)

Fix

- **TestClient**: call task_done after the topic has consumed the cr (138)

Has known vulnerabilities

Previous Next