FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
APACHE-2.0 License
Bot releases are visible (Hide)
Published by davorrunje over 1 year ago
Published by davorrunje over 1 year ago
Published by davorrunje over 1 year ago
Initial release
Published by davorrunje over 1 year ago
Enable FastKafka reentrancy (#92)
Add cleanup of stale producers in populate_producers and close_producers methods
Allocation of random port in LocalKafkaBroker (#80)
Zookeeper random port allocation
Kafka random port allocation
Create missing topics in LocalKafkaBroker (#79)
add topics function to KafkaApp for listing topics
Implement creation of topics in LocalKafkaBroker
Wait for topics to be created in Broker
Implement FastKafka Tester class (#75)
Implement mirroring of consumers and producers
Release polishing (#69)
Transfer nest-asyncio requirement to dev requirements
Replace Ilock with posix_ipc
Implement mechanism for port allocation in LocalKafkaBroker
Cleanup logging in LocalKafkaBoker
Create LocalKafkaBroker class (#66)
Start LocalKafkaBroker in testing (#65)
ESAKafka mockup (#62)
Mockup services for ESA
Test mockups
Integrate static check changes from workflow repository (#59)
Refactor consumer_loop (#43)
Rework process_msgs tests to use mock patching
Remove creating and sending async callback to process stream every time when msg is consumed
Write docs
Fix failing CI tests
Add better exception handling in consumer callbacks (#37)
Implement mechanism for registering actions after startup (#35)
Make FastKafkaAPI not inherit from FastAPI (#34)
Implement sync and async variants for producer decorator (#22)
Add Kafka healthcheck in CI (#11)
CLI command for exporting async docs (#8)
Enable FastKafka reentrancy (#92)
Add cleanup of stale producers in populate_producers and close_producers methods
FastKafka context manager aenter and aexit unuseable separately because of TaskGroup exceptions when closing (#91)
Replace task group with asyncio.create_task calls to enable using aenter and aexit methods in FastKafk
Release polishing (#69)
Transfer nest-asyncio requirement to dev requirements
Replace Ilock with posix_ipc
Implement mechanism for port allocation in LocalKafkaBroker
Cleanup logging in LocalKafkaBoker
Fastkafka CLI run workers does not output log messages until cancelled (#60)
Write a warning in the 02_First_Steps for flushing
Fix export_async_spec failing when @consumes function has a return type None (#48)
Fix silent failing in guides when executing example scripts (#44)
Assert exit_code is equal to 0 when run_script_and_cancel runs
Add tests for run_script_and_cancel helper function
Check log levels for Guide_02_First_steps
Published by davorrunje almost 2 years ago
Published by davorrunje almost 2 years ago
Published by davorrunje almost 2 years ago
Documentation polishing and Semgrep scan added
Published by davorrunje almost 2 years ago
Initial release