v0.8.0

New Features

• 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

Bugs Squashed

• 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

v0.7.1

Bugs Squashed

• Limit pydantic version to <2.0 (#427)

• Fix Kafka broker version installation issues (#427)

• Fix ApacheKafkaBroker startup issues (#427)

v0.7.0

New Features

• 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

• 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]

• Removed support for synchronous produce functions (#295), thanks to @kumaranvpl

• Added default broker values and update docs (#292), thanks to @Sternakt

Bugs Squashed

• 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

• 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

v0.6.1

Bugs Squashed

• Fixed topics with dots causing failure of tester instantiation (#305), thanks to @Sternakt

v0.6.0

New Features

• 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.

• 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)

Bugs Squashed

• Batch testing fix (#280), thanks to @Sternakt

• Tester breaks when using Batching or KafkaEvent producers (#279)

• Consumer loop callbacks are not executing in parallel (#276)

v0.5.0

New Features

• Significant speedup of Kafka producer (#236), thanks to @Sternakt

• Added support for AVRO encoding/decoding (#231), thanks to @kumaranvpl

Bugs Squashed

• 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

v0.4.0

New Features

• 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)

  • https://www.linkedin.com/posts/tiangolo_fastapi-activity-7038907638331404288-Oar3/?utm_source=share&utm_medium=member_ios

v0.3.1

• README.md file updated

v0.3.0

New Features

• 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)

Bugs Squashed

• 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)

v0.3.0rc2

New Features

• 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)

Bugs Squashed

• Fix the helper.py link in CHANGELOG.md (#165)