v1.1.0

Add monitoring for event consumption tasks.

v1.0.0

What's Changed

• Fix github url strings (org edx -> openedx) by @sarina in #40
• build: add upgrade requirement workflow by @aht007 in #47
• chore: Upgrade versions of GitHub actions by @timmc-edx in #46
• Python Requirements Update by @edx-requirements-bot in #49
• fix: send schema to fully-qualified topic when using topic prefixes by @rgraber in #50

New Contributors

• @sarina made their first contribution in #40
• @aht007 made their first contribution in #47
• @edx-requirements-bot made their first contribution in #49

Full Changelog: v0.7.0...v1.0.0

v0.7.0

What's Changed

• refactor!: add KafkaEventConsumer to public API and rename EventProducerKafka by @rgraber in #44

Full Changelog: v0.6.2...v0.7.0

v0.6.2: feat: Add topic prefix when configured (EVENT_BUS_TOPIC_PREFIX) (#42)

Added:

• Topic names can be autoprefixed by setting EVENT_BUS_TOPIC_PREFIX

v0.6.1

Added:

• Producer now polls on an interval, improving callback reliability. Configurable with EVENT_BUS_KAFKA_POLL_INTERVAL_SEC.

v0.6.0

Changed:

• Breaking change: Public API is now defined in edx_event_bus_kafka package (new) and edx_event_bus_kafka.management.commands package (existing, unchanged); all other modules should be considered unstable and not for external use.

v0.5.1: style: Add missing `__init__.py` files and fix lint issues (#36)

Fixed:

• Various lint issues (and missing __init__.py files.)

v0.5.0

Changed:

• Breaking changes in the producer module, refactored to expose a better API:
  • Rather than send_to_event_bus(...), relying code should now call get_producer().send(...).
  • The sync kwarg is gone; to flush and sync messages before shutdown, call get_producer().prepare_for_shutdown() instead.
• Clarify that config module is for internal use only.
• Implementation changes: Only a single Producer is created, and is used for all signals.

v0.4.4

Fixed:

• Fixed bug in test module for when confluent-kafka isn't present

v0.4.3

Fixed:

• Never evict producers from cache. There wasn't a real risk of this, but now we can rely on them being long-lived. Addresses remainder of #16.