Как соединить данные из разных топиков Apache Kafka с помощью пары SQL-запросов: коннекторы, материализованные представления и потоковая база данных вместо полноценного потребителя. Подробная демонстрация запросов в RisingWave. Вчера я показывала пример потоковой агрегации данных из разных топиков Kafka с помощью Python-приложения, которое потребляет данные о пользователях и событиях их поведения на сайтах из разных топиков Kafka и соединяет их по ключевому идентификатору. Сегодня рассмотрим, как решить эту задачу быстрее с помощью потоковой базы данных RisingWave и коннекторов к Kafka...

С 1 сентября 2020 года участники оборота товарной группы Молоко передают сведения о движении продукции через ЭДО в разрезе объемно-сортового учета, а магазины продают маркированную молочную продукцию сканируя DataMatrix и подавая сведения об их выбытии в систему маркировки. Следующий этап развития системы маркировки – поэкземплярный учет, когда будет отслеживаться движение каждой конкретной упаковки товара. Для молока эта дата – 1 июня 2025 года. (Сроки развития системы маркировки "Честный ЗНАК" разные для разных товарных групп)...