Привет! Есть вопрос про кафка стримы. Про GlobalKTable. Судя по всему store который там используется хранит данные в массивах байт. И каждый раз когда данные запрашиваются он делает десериализацию. Это так? Если это так то почему?
Привет! Есть вопрос про кафка стримы. Про GlobalKTable. Судя по всему store который там используется хранит данные в массивах байт. И каждый раз когда данные запрашиваются он делает десериализацию. Это так? Если это так то почему?
Потому что State store по умолчанию используется Rocksdb. а это уже шаг за пределы Jvm (Offheap такой). А всегда когда объекты надо вынести за пределы Jvm надо сериализовать и десериализовать
Потому что State store по умолчанию используется Rocksdb. а это уже шаг за пределы Jvm (Offheap такой). А всегда когда объекты надо вынести за пределы Jvm надо сериализовать и десериализовать
А почему нельзя использовать какой то in memory store для global ktable?
Просто получается что global ktable бесполезна вроде как если не важен порядок процессинга рекордов из неё. Например мы были вынуждены имплементировать свой in memory storage поверх кафка топика. Потому что разница в перформансе довольно существенна. Есть какие то планы насчёт этого у разрабов кафки?