Skip to content

feat(consumer): scaffold KIP-932 share consumer surface #838

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Draft
j7nw4r wants to merge 13 commits into
base: master
Choose a base branch
from
Draft

feat(consumer): scaffold KIP-932 share consumer surface #838

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
1015894
Sanitize ClientConfig and AdminClient debugging
j7nw4r Oct 2, 2025
51a1a97
Cargo fmt for check happiness.
j7nw4r Oct 2, 2025
924b927
docs: add KIP-932 share consumer implementation plan
j7nw4r May 23, 2026
32df147
docs: note PLAN.md is iterated in a draft PR pending librdkafka
j7nw4r May 23, 2026
f2efe9a
feat(consumer): add kip-932 feature flag and share module skeleton
j7nw4r May 23, 2026
db9d384
feat(consumer/share): add AcknowledgeType and configuration types
j7nw4r May 23, 2026
e377065
feat(error): add KafkaError::Unsupported variant
j7nw4r May 23, 2026
1cf31d0
feat(consumer/share): add ShareConsumer trait and BaseShareConsumer stub
j7nw4r May 23, 2026
a1cb6ae
test(consumer/share): broker-free smoke tests for the KIP-932 surface
j7nw4r May 23, 2026
ecb1655
style(consumer/share): apply rustfmt to share module
j7nw4r May 23, 2026
a4b2e2a
ci: add kip-932 lanes to lint and check jobs
j7nw4r May 23, 2026
ea42fc8
docs: document KIP-932 share consumer scaffolding
j7nw4r May 23, 2026
ce088f6
fix(consumer/share): elide needless lifetime on ShareRecord impl
j7nw4r May 23, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 6 additions & 0 deletions .github/workflows/ci.yml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,11 @@ jobs:
- run: cargo fmt -- --check
- run: cargo clippy -- -Dwarnings
- run: cargo clippy --tests -- -Dwarnings
- run: cargo clippy --features kip-932 -- -Dwarnings
- run: cargo clippy --features kip-932 --tests -- -Dwarnings
- run: cargo test --doc
- run: cargo test --features kip-932 --lib consumer::share
- run: cargo test --features kip-932 --test test_share_consumer

check:
strategy:
Expand All @@ -33,6 +37,8 @@ jobs:
rdkafka-sys-features: cmake-build,libz-static,curl-static
- os: ubuntu-24.04
features: tracing
- os: ubuntu-24.04
features: kip-932
- os: ubuntu-24.04
features: cmake-build,ssl-vendored,gssapi-vendored,libz-static,curl-static,zstd
rdkafka-sys-features: cmake-build,ssl-vendored,gssapi-vendored,libz-static,curl-static,zstd
Expand Down
7 changes: 6 additions & 1 deletion Cargo.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -66,9 +66,14 @@ zstd-pkg-config = ["rdkafka-sys/zstd-pkg-config"]
external-lz4 = ["rdkafka-sys/external-lz4"]
external_lz4 = ["rdkafka-sys/external_lz4"]
static-linking = ["rdkafka-sys/static-linking"]
# Opt in to the KIP-932 (Queues for Kafka) share consumer surface. The Rust
# types ship now so downstream crates can compile against the API shape, but
# runtime methods return `KafkaError::Unsupported` until librdkafka exposes
# the public share consumer C API (tracking confluentinc/librdkafka#5441).
kip-932 = []

[package.metadata.docs.rs]
# docs.rs doesn't allow writing to ~/.cargo/registry (reasonably), so we have to
# use the CMake build for a proper out-of-tree build.
features = ["cmake-build", "naive-runtime", "tracing", "tokio"]
features = ["cmake-build", "naive-runtime", "tracing", "tokio", "kip-932"]
rustdoc-args = ["--cfg", "docsrs"]
Loading
Loading