BDD Test Coverage Roadmap

Cross-SDK BDD test implementation progress. Shared .feature files live in bdd/scenarios/; each SDK implements step definitions in its own directory. Related: #2148.

Rust already has extensive integration test coverage for most of these features under core/integration/tests/server/scenarios/. These serve as the reference implementation. The goal is to promote them into shared Gherkin .feature files and implement step definitions across all SDKs.

The BDD tests should expand coverage beyond what the Rust integration tests already verify. The integration tests check internal server state (on-disk files, in-memory structures). The BDD tests verify end-to-end client-visible behavior through the full stack (SDK → wire protocol → server) and should systematically add scenarios the integration tests don't cover:

• Cross-resource isolation (does purging stream A break stream B?)
• Error cases (non-existing IDs, invalid inputs)
• Multi-resource operations (purge stream vs purge topic)
• Repeated operations after mutation (send → purge → send → poll)

Master Progress Table

Each SDK checkbox means: .feature file exists in bdd/scenarios/ AND that SDK's step definitions pass in CI.

basic_messaging

Create a stream, topic, send 10 messages, poll them back, verify offsets and payloads.

1 scenario in bdd/scenarios/basic_messaging.feature

leader_redirection

Client redirects from follower to leader; direct leader connect; single-server fallback; multiple clients converge to same leader.

4 scenarios in bdd/scenarios/leader_redirection.feature. Requires cluster compose.

stream_crud

Create, get-by-id, list-all, update, delete streams.

• Rust reference: core/integration/tests/cli/stream/test_stream_{create,delete,get,list,update}_command.rs

topic_crud

Create, get-by-id, list-all, update, delete topics within a stream.

• Rust reference: core/integration/tests/cli/topic/test_topic_{create,delete,get,list,update}_command.rs

consumer_group

Create, get-by-id, list-all, delete consumer groups. Join and leave consumer groups.

• Rust reference: core/integration/tests/server/scenarios/consumer_group_join_scenario.rs, consumer_group_duplicate_name_create_scenario.rs, consumer_group_with_single_client_polling_messages_scenario.rs, consumer_group_with_multiple_clients_polling_messages_scenario.rs

consumer_offset

Store/retrieve consumer offsets. Verify auto-commit and offset correctness.

• Rust reference: core/integration/tests/server/scenarios/offset_scenario.rs, invalid_consumer_offset_scenario.rs, consumer_group_auto_commit_reconnection_scenario.rs, consumer_group_offset_cleanup_scenario.rs

user_management

Create, update, delete users. Change password. Assign and verify permissions.

• Rust reference: core/integration/tests/server/scenarios/user_scenario.rs, permissions_scenario.rs

personal_access_token

Create with expiry, list, revoke PATs. Authenticate with a token. Verify expiry and scoping.

• Rust reference: core/integration/tests/server/scenarios/cross_protocol_pat_scenario.rs

message_operations

Send messages with custom headers. Poll with offset/consumer-group semantics. Verify header round-trip. Verify header size limit (≤ 64 KB).

• Rust reference: core/integration/tests/server/scenarios/message_headers_scenario.rs, message_size_scenario.rs, create_message_payload.rs, single_message_per_batch_scenario.rs

partition_management

Create and delete partitions on an existing topic. Verify partition count updates.

• Rust reference: core/integration/tests/cli/partition/test_partition_{create,delete}_command.rs

system_operations

Fetch server stats (PID, memory, CPU, counts). Ping. Fetch client info.

• Rust reference: core/integration/tests/server/scenarios/system_scenario.rs, core/integration/tests/cli/system/test_{ping,stats,snapshot}_*.rs

stream_topic_purge

Purge stream (all topics); purge single topic; verify isolation between streams; verify isolation between topics; error on non-existing stream; error on non-existing topic.

6 scenarios in bdd/scenarios/stream_topic_purge.feature

• Rust reference: core/integration/tests/server/scenarios/purge_delete_scenario.rs (run_purge_topic)

snapshot

Create and restore file-based snapshots. Verify data integrity after restore.

• Rust reference: core/integration/tests/server/scenarios/snapshot_scenario.rs

raw_command

Send a command code with a payload directly, so commands that have no typed SDK method can be called. Verify round-trips for
known codes, rejection for unknown and session-control codes.

3 scenarios in bdd/scenarios/raw_command.feature

rawcommand