rustfs-kafka-async 1.2.0

Async Kafka client built on tokio
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
39
40
41
42
43

# rustfs-kafka-async Agent Notes

Scope: async wrapper crate for `rustfs-kafka`.
Current release target: `1.2.0`.

## What This Crate Owns

- `AsyncKafkaClient`
- `AsyncProducer`
- `AsyncConsumer`
- native async transport and lifecycle management

## Design Constraints

- Keep wrappers lightweight and focused on async ergonomics.
- Delegate protocol correctness to `rustfs-kafka`.
- Ensure graceful shutdown semantics (`close`) remain predictable.
- Preserve error mapping consistency with the sync crate.

## Validation

```bash
cargo test -p rustfs-kafka-async
cargo clippy -p rustfs-kafka-async --all-targets --all-features -- -D warnings
```

If async changes impact sync behavior assumptions, run integration checks in
`crates/rustfs-kafka/tests`.

Secure SASL coverage:

```bash
cd crates/rustfs-kafka/tests
./run-async-secure-tests
```

## Docs Sync

When async APIs change:

- update `crates/rustfs-kafka-async/README.md`,
- update `docs/usage-guide.md`,
- add a changelog entry in `CHANGELOG.md`.