-
Add support for Pydantic v2 (#408), thanks to @kumaranvpl
- FastKafka now uses Pydantic v2 for serialization/deserialization of messages
-
Enable nbdev_test on windows and run CI tests on windows (#356), thanks to @kumaranvpl
-
Fix ´fastkafka testing install deps´ failing (#385), thanks to @Sternakt
-
Create asyncapi docs directory only while building asyncapi docs (#368), thanks to @kumaranvpl
-
Add retries to producer in case of raised KafkaTimeoutError exception (#423), thanks to @Sternakt
-
Limit pydantic version to <2.0 (#427)
-
Fix Kafka broker version installation issues (#427)
-
Fix ApacheKafkaBroker startup issues (#427)
-
Optional description argument to consumes and produces decorator implemented (#338), thanks to @Sternakt
- Consumes and produces decorators now have optional
description
argument that is used instead of function docstring in async doc generation when specified
- Consumes and produces decorators now have optional
-
FastKafka Windows OS support enabled (#326), thanks to @kumaranvpl
- FastKafka can now run on Windows
-
FastKafka and FastAPI integration implemented (#304), thanks to @kumaranvpl
- FastKafka can now be run alongside FastAPI
-
Batch consuming option to consumers implemented (#298), thanks to @Sternakt
- Consumers can consume events in batches by specifying msg type of consuming function as
List[YourMsgType]
- Consumers can consume events in batches by specifying msg type of consuming function as
-
Removed support for synchronous produce functions (#295), thanks to @kumaranvpl
-
Added default broker values and update docs (#292), thanks to @Sternakt
-
Fix index.ipynb to be runnable in colab (#342)
-
Use cli option root_path docs generate and serve CLI commands (#341), thanks to @kumaranvpl
-
Fix incorrect asyncapi docs path on fastkafka docs serve command (#335), thanks to @Sternakt
- Serve docs now takes app
root_path
argument into consideration when specified in app
- Serve docs now takes app
-
Fix typo (supress_timestamps->suppress_timestamps) and remove fix for enabling timestamps (#315)
-
Fix logs printing timestamps (#308)
-
Fix topics with dots causing failure of tester instantiation (#306), thanks to @Sternakt
- Specified topics can now have "." in their names
-
Timestamps added to CLI commands (#283), thanks to @davorrunje
-
Added option to process messages concurrently (#278), thanks to @Sternakt
- A new
executor
option is added that supports either sequential processing for tasks with small latencies or concurrent processing for tasks with larger latencies.
- A new
-
Add consumes and produces functions to app (#274), thanks to @Sternakt
-
Add batching for producers (#273), thanks to @Sternakt
-
requirement(batch): batch support is a real need! and i see it on the issue list.... so hope we do not need to wait too long
https://discord.com/channels/1085457301214855171/1090956337938182266/1098592795557630063
-
-
Fix broken links in guides (#272), thanks to @harishmohanraj
-
Generate the docusaurus sidebar dynamically by parsing summary.md (#270), thanks to @harishmohanraj
-
Metadata passed to consumer (#269), thanks to @Sternakt
-
requirement(key): read the key value somehow..Maybe I missed something in the docs requirement(header): read header values, Reason: I use CDC | Debezium and in the current system the header values are important to differentiate between the CRUD operations.
https://discord.com/channels/1085457301214855171/1090956337938182266/1098592795557630063
-
-
Contribution with instructions how to build and test added (#255), thanks to @Sternakt
-
Export encoders, decoders from fastkafka.encoder (#246), thanks to @kumaranvpl
-
Create a Github action file to automatically index the website and commit it to the FastKafkachat repository. (#239)
-
UI Improvement: Post screenshots with links to the actual messages in testimonials section (#228)
-
Tester breaks when using Batching or KafkaEvent producers (#279)
-
Consumer loop callbacks are not executing in parallel (#276)
-
Significant speedup of Kafka producer (#236), thanks to @Sternakt
-
Added support for AVRO encoding/decoding (#231), thanks to @kumaranvpl
-
Fixed sidebar to include guides in docusaurus documentation (#238), thanks to @Sternakt
-
Fixed link to symbols in docusaurus docs (#227), thanks to @harishmohanraj
-
Removed bootstrap servers from constructor (#220), thanks to @kumaranvpl
-
Integrate FastKafka chat (#208), thanks to @harishmohanraj
-
Add benchmarking (#206), thanks to @kumaranvpl
-
Enable fast testing without running kafka locally (#198), thanks to @Sternakt
-
Generate docs using Docusaurus (#194), thanks to @harishmohanraj
-
Add test cases for LocalRedpandaBroker (#189), thanks to @kumaranvpl
-
Reimplement patch and delegates from fastcore (#188), thanks to @Sternakt
-
Rename existing functions into start and stop and add lifespan handler (#117)
- README.md file updated
-
Guide for FastKafka produces using partition key (#172), thanks to @Sternakt
- Closes #161
-
Add support for Redpanda for testing and deployment (#181), thanks to @kumaranvpl
-
Remove bootstrap_servers from init and use the name of broker as an option when running/testing (#134)
-
Add a GH action file to check for broken links in the docs (#163)
-
Optimize requirements for testing and docs (#151)
-
Break requirements into base and optional for testing and dev (#124)
- Minimize base requirements needed just for running the service.
-
Add link to example git repo into guide for building docs using actions (#81)
-
Add logging for run_in_background (#46)
-
Implement partition Key mechanism for producers (#16)
-
Implement checks for npm installation and version (#176), thanks to @Sternakt
- Closes #158 by checking if the npx is installed and more verbose error handling
-
Fix the helper.py link in CHANGELOG.md (#165)
-
fastkafka docs install_deps fails (#157)
- Unexpected internal error: [Errno 2] No such file or directory: 'npx'
-
Broken links in docs (#141)
-
fastkafka run is not showing up in CLI docs (#132)
- Fixed broken links on PyPi index page
-
Extract JDK and Kafka installation out of LocalKafkaBroker (#131)
-
PyYAML version relaxed (#119), thanks to @davorrunje
-
Replace docker based kafka with local (#68)
- replace docker compose with a simple docker run (standard run_jupyter.sh should do)
- replace all tests to use LocalKafkaBroker
- update documentation
-
Fix broken link for FastKafka docs in index notebook (#145)
-
Fix encoding issues when loading setup.py on windows OS (#135)
- Replace kafka container with LocalKafkaBroker (#112)
-
- Replace kafka container with LocalKafkaBroker in tests
-
- Remove kafka container from tests environment
- Fix failing tests
- Fix random failing in CI (#109)
- version update in init.py
- Git workflow action for publishing Kafka docs (#78)
- Include missing requirement (#110)
- Typer is imported in this file but it is not included in settings.ini
- Add aiohttp which is imported in this file
- Add nbformat which is imported in _components/helpers.py
- Add nbconvert which is imported in _components/helpers.py
- JDK install fails on Python 3.8 (#106)
Initial release