ack после хранилища сейчас
Каждая пачка durable-сохраняется в S3/MinIO или на файловую систему ДО подтверждения продюсеру. Между «принял» и «сохранил» потерь нет — по построению.
Roxa не привязывает данные к диску конкретного брокера. Вместо этого записи группируются в памяти и durable-сохраняются в объектное хранилище — модель diskless. Отсюда два свойства: брокер near-stateless (упал — поднялся новый и читает из S3), а подтверждение приходит только после фактической записи. Ниже — путь сообщения.
Сообщения принимаются, каждому присваивается монотонный offset — порядок в партиции гарантирован.
Записи многих продюсеров копятся в памяти считанные десятки миллисекунд, чтобы не делать тысячи мелких обращений к хранилищу.
Накопленная пачка одним объектом уходит в S3/MinIO и становится durable.
Продюсер получает ack только когда объект зафиксирован в хранилище. Между «принял» и «сохранил» потери нет.
Каждая пачка durable-сохраняется в S3/MinIO или на файловую систему ДО подтверждения продюсеру. Между «принял» и «сохранил» потерь нет — по построению.
Режим с локальным журналом для ещё более быстрого ack при той же надёжности — для сценариев с жёсткими требованиями к латентности.
Хранилище выбираете вы: S3/MinIO или локальная файловая система — одним параметром конфига.
| Roxa | Apache Kafka | Redpanda | |
|---|---|---|---|
| Хранилище данных | S3 (diskless) | Диски брокеров | Диски + tiered |
| Рантайм | Rust, без JVM | JVM + ZK/KRaft | C++ |
| Потеря при падении узла | Нет — данные в S3 | Возможна до репликации | Возможна |
| Старт | Один бинарь | Кластер + координация | Кластер |
| Kafka-клиенты | Да | Да | Да |
| Цена владения | Лицензия навсегда, минимум эксплуатации | Бесплатно + команда эксплуатации | Enterprise-подписка вендора (США) |
Латентность зависит от режима durability и хранилища: на локальном NVMe/MinIO — десятки миллисекунд, на удалённом S3 — выше. Мы не обещаем цифр, которые не выдержим.