Redpanda-rs

Rust用于与Redpanda消息代理交互的包。

基于C库librdkafka及其rust绑定。

提供一层抽象，使在Rust中使用Redpanda（和其他Kafka-like）消息代理更容易。

docker exec-it redpanda-0bash

更改段大小

rpk topic alter-config <topic> --set segment.bytes=<segment_size> rpk topic alter-config simple --set segment.bytes=1000000

启动本地Redpanda和MinIO集群

docker compose up

在Redpanda控制台上检查代理状态

https://127.0.0.1:8080

参考资料

librdkafka文档

• librdkafka维基
• librdkafka讨论
• 手动设置消费者起始偏移量