Kstreams

Latest version: v0.18.5

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

Scan your dependencies

Page 3 of 14

Refactor

- Updated code to Pydantic 2.0 (get rid of deprecation warnings) (156)

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)

Has known vulnerabilities

Previous Next