High performance
Instant Messaging Systems
ITSumma corporate blog
Apache
Big Data
Comments 3
0
Мне кажется вы привели слишком много примеров использования с хранением объектов в kafaka. Но это не рекомендуется для событийно ориентированных приложений.
При такой схеме каждому сервису нужно самому разбираться в изменениях объекта, а для этого их нужно сохранять (хотя бы частично) в локальной бд сервиса. Такое приводит к колоссальному дублирования данных.
0
По-моему, для этого в Kafka есть schema-registry: там можно мониторить изменения схемы данных объекта. И не надо локально отслеживать изменение модели объекта.
0

Не очень пока знаком с Kafka, что такое «уплотнение журнала»? Можете привести пример?


А что насчёт возможность фильтрации сообщений при чтении журнала? Можно ли получить сообщения из журнала, отфильтрованные по user_id и/или которые больше/меньше определенного времени?


Есть ли у Kafka механизмы обработки/преобразования входящих сообщений (кроме упомянутого партиционирования)?

Only those users with full accounts are able to leave comments. , please.