Было бы интересно ещё узнать о процессах появления данных в брокерам . А также о процедуре переинициализации при сбоях, повлекших потерю интервала данных?
Не думали использовать продукты confluent. Понятно что не будет универсальности, т.к. будет поддержка только Kafka. Но работа в тандеме со Schema Registry вроде как решает проблему изменения схемы, а также обеспечивает контроль версий схем. Да и RabbitMQ можно прогнать через Kafka.
Сразу вспомнил про эту статью
https://habr.com/ru/articles/846296/.
Ещё не немного понадоедаю. ))
Было бы интересно ещё узнать о процессах появления данных в брокерам . А также о процедуре переинициализации при сбоях, повлекших потерю интервала данных?
Расскажите, пожалуйста, как используете брокеры. Как временный буфер (время жизни сообщения допустим неделя) или с постоянным хранение истории?
Не думали использовать продукты confluent. Понятно что не будет универсальности, т.к. будет поддержка только Kafka. Но работа в тандеме со Schema Registry вроде как решает проблему изменения схемы, а также обеспечивает контроль версий схем. Да и RabbitMQ можно прогнать через Kafka.
Можно уточнить эту конструкцию, точно необходимо проверять срез, а не последний элемент?