hluk / waiverdb

LAST BUILD ON BRANCH kafka

branch: SELECT

CHANGE BRANCH

x

Sync Branches

• No branch selected
• add-image-expiration
• auth-errors
• avoid-updating-python-version
• bump-base-image
• dependabot/pip/cryptography-37.0.2
• dependabot/pip/cryptography-37.0.4
• dependabot/pip/cryptography-38.0.1
• dependabot/pip/cryptography-38.0.3
• dependabot/pip/flask-migrate-4.0.0
• dependabot/pip/flask-migrate-4.0.3
• dependabot/pip/mock-5.0.0
• dependabot/pip/mock-5.0.1
• dependabot/pip/pip-22.3.1
• dependabot/pip/setuptools-67.0.0
• dependabot/pip/sphinx-6.0.0
• dependabot/pip/sphinx-6.1.2
• dependabot/pip/sphinx-6.1.3
• dependabot/pip/sphinxcontrib-httpdomain-1.8.1
• dependabot/pip/sqlalchemy-1.4.37
• dependabot/pip/sqlalchemy-1.4.39
• dependabot/pip/sqlalchemy-1.4.40
• dependabot/pip/sqlalchemy-1.4.41
• dependabot/pip/sqlalchemy-1.4.42
• dependabot/pip/sqlalchemy-1.4.44
• dependabot/pip/sqlalchemy-1.4.45
• dependabot/pip/sqlalchemy-1.4.46
• dependabot/pip/stomp-py-8.1.0
• dependabot/pip/werkzeug-lt-2.3
• dependabot/pip/wheel-0.38.4
• docker-compose-sync
• drop-flask-restful
• drop-waiverdb-cli
• fix-about-version
• fix-docs-build
• fix-duplicate-session
• fix-example-subject-type
• fix-flaky-test
• fix-lock-file-maintenance-schedule
• fix-migrations
• fix-new-sqlalchemy
• fix-oidc-token
• fix-stomp-version
• fix-tests
• fix-tox
• fix-tracing
• fix-werkzeug
• hatch
• kafka
• keycloak
• master
• oidc-login-form
• pdm
• permission-include-following
• poetry
• postgres-update
• pydantic2
• python-3.11
• python-3.12-for-renovatebot
• python-3.13
• refactor-oidc-token
• renovate
• renovate-lock
• revert-werkzeug
• secure-cookies
• show-permissions-warning
• simplify-log-config
• split-permission-users-groups
• sync-with-greenwave
• update
• update-authlib
• update-dependencies
• update-dependencies-monthly
• update-opentelemetry
• update-otel
• update-pydantic
• update-readthedocs
• uv
• uv-3

Build # 21134232715

Build Type

push

github

Committed by hluk

Commit Message

Add support for Kafka

Claude Code prompts:

> Add support for publishing messages using Kafka to @waiverdb/events.py.
> `MESSAGE_PUBLISHER` option in configuration will support new "kafka"
> value (in addition to the current "fedmsg" and "stomp" values). Any
> other required configuration can be added to @waiverdb/config.py

> Move Kafka code from @waiverdb/events.py to separate submodule
> waiverdb/messaging/kafka.py.

> Write tests for the new kafka code and configuration option.

Assisted-by: Claude Code

Run Details

237 of 332 branches covered (71.39%)

Branch coverage included in aggregate %.

195 of 203 new or added lines in 5 files covered. (96.06%)

6 existing lines in 1 file now uncovered.

2166 of 2486 relevant lines covered (87.13%)

0.87 hits per line