Skip to content

Changelog

All notable changes to this project will be documented in this file.

The format is based on Keep a Changelog, and this project adheres to Semantic Versioning.

[0.1.0] - 2026-07-10

Added

  • @kafka_consumer(topic, group_id=) marker for component methods (sync and async); JSON record values decoded before dispatch.
  • @kafka_producer / @produce(topic) declarative producing clients (sync stubs block on ack, async stubs await).
  • KafkaRegistrar: dedicated background asyncio loop; one aiokafka consumer task per subscribed method; skip-on-failure policy so poison records never stall a partition; everything stopped on container shutdown.
  • Settings under the kafka prefix: bootstrap_servers, enabled, group_id, produce_timeout_seconds (zero-config).
  • Auto-discovery via the pico_boot.modules entry point.