kafkit-client 0.1.1

Kafka 4.0+ pure Rust client.
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

# Admin

- Create topics.
- Delete topics.
- List topics.
- Describe topics.
- Describe cluster.
- List consumer groups.
- Describe consumer groups.
- Describe configs.
- Alter configs.

```rust
use kafkit_client::{AdminConfig, KafkaAdmin, NewTopic};

# async fn example() -> kafkit_client::Result<()> {
let admin = KafkaAdmin::connect(AdminConfig::new("localhost:9092")).await?;
admin.create_topics([NewTopic::new("orders", 3, 1)]).await?;
let topics = admin.list_topics().await?;
# let _ = topics;
# Ok(())
# }
```