Skip to main content
Version: dev 🚧

Release notes

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

0.7.1​

Bugs Squashed​

  • Limit pydantic version to <2.0 (#427)

  • Fix Kafka broker version installation issues (#427)

  • Fix ApacheKafkaBroker startup issues (#427)

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

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

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

0.5.0​

New Features​

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

Bugs Squashed​

0.4.0​

New Features​

0.3.1​

  • README.md file updated

0.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)

0.2.3​

  • Fixed broken links on PyPi index page

0.2.2​

New Features​

  • 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

Bugs Squashed​

  • Fix broken link for FastKafka docs in index notebook (#145)

  • Fix encoding issues when loading setup.py on windows OS (#135)

0.2.0​

New Features​

  • Replace kafka container with LocalKafkaBroker (#112)
      • Replace kafka container with LocalKafkaBroker in tests
  • Remove kafka container from tests environment
  • Fix failing tests

Bugs Squashed​

  • Fix random failing in CI (#109)

0.1.3​

  • version update in init.py

0.1.2​

New Features​

  • Git workflow action for publishing Kafka docs (#78)

Bugs Squashed​

  • 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

0.1.1​

Bugs Squashed​

  • JDK install fails on Python 3.8 (#106)

0.1.0​

Initial release