У меня есть миллионы устройств IOT.
каждое устройство отправляет свои данные на мой сервер.
моя служба разбирает данные и выводит их в тему Кафки
У меня есть другое приложение, которое использует тему, как упомянуто выше, делает некоторую логику и превращает ее в другую тему.
скажем, что каждое устройство имеет уникальный идентификатор устройства, и я хотел бы предотвратить дублирование (иногда устройства отправляют его)
Я хотел бы сохранить последние 10 записей для каждого устройства:
deviceID = 1234 -> список последних 10 записей
поэтому, когда я получу этот deviceID снова, я смогу отбросить его, поскольку он написан как часть KTABLE.
имеет ли смысл? я могу это реализовать? это есть лучший способ?