VG
О, ответил быстрее, чем я спросил. Ага, просто сахар )
Не просто сахар
Size: a a a
2021 January 09
PD
Ну, благодаря транзакциям и так можно было. Это же новый топик создается?
PD
И нужно помещаться в общий лимит по партициям? Или нет?
VG
Ну, благодаря транзакциям и так можно было. Это же новый топик создается?
Ещё раз - топик можно и не создать. В коде у товарища нет метода to() который запишет все в новый топик
VG
И нужно помещаться в общий лимит по партициям? Или нет?
VG
И нужно помещаться в общий лимит по партициям? Или нет?
Нипонил
PD
Если делать matview (т.е. с незавимым хранением), то это уже не просто consumer group поверх топика, а новый топик?
PD
И у этого топика есть свои партиции и нужно влезть в 200k партиций?
VG
Если делать matview (т.е. с незавимым хранением), то это уже не просто consumer group поверх топика, а новый топик?
Не обязательно. Можно хранить в rocksdb
PD
Кстати, а на число consumer group есть ограничение? Их модет быть 10mln на один топик с 1000 партиций?
PD
Не обязательно. Можно хранить в rocksdb
Ну, я вот хочу без rocksdb обойтись. мне не хочется еще одну сущность поддерживать.
PD
Я пытаюсь решить задачу с кучей небольших дешёвых очередей. Типа 10mln, но почти без событий.
VG
Ну, я вот хочу без rocksdb обойтись. мне не хочется еще одну сущность поддерживать.
Тебе не надо rocksdb поддерживать - это embedded база, часть Java приложения Kafka Streams. Только offheap
VG
Я пытаюсь решить задачу с кучей небольших дешёвых очередей. Типа 10mln, но почти без событий.
А зачем?
PD
Акторы, workflow и т.п
VG
Я пытаюсь решить задачу с кучей небольших дешёвых очередей. Типа 10mln, но почти без событий.
VG
Акторы, workflow и т.п
Да, но зачем?