rustfs-kafka 1.2.0

Rust client for Apache Kafka
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

# rustfs-kafka Agent Notes

Scope: synchronous core crate.
Current release target: `1.2.0`.

## What This Crate Owns

- `client/`: KafkaClient and low-level request/response workflows.
- `consumer/`: high-level consumer state machine and offset commit flow.
- `producer/`: high-level producer APIs (including batch/transactional).
- `protocol/`: Kafka protocol building/parsing via `kafka-protocol`.
- `network/`: connection and pooling logic.
- `tls/`: rustls connector paths.

## High-Risk Change Areas

- Consumer offset semantics (`consume_messageset`, `commit_consumed`).
- Protocol version negotiation and request encoding.
- Reconnection/retry behavior in network and client layers.
- Security mode configuration (`security` / `security-ring` feature paths).

## Required Test Coverage for Risky Changes

```bash
cargo test -p rustfs-kafka
cargo clippy -p rustfs-kafka --all-targets --all-features -- -D warnings
cd tests && ./run-all-tests 3.9.2:4.1.2:4.2.0
```

If a change is specific to secure paths, include secure matrix validation.

## Documentation Sync

When behavior changes:

- update root `README.md` if end-user visible,
- update `docs/usage-guide.md` and/or `docs/api-guide.md`,
- record in `CHANGELOG.md`.