У меня есть приложение kafka с несколькими производителями и потребителями, где я создаю записи для одной темы, и через некоторое время я использую группу записей из той же темы (например, 5 записей), и после этого мне нужно получить последнюю записьдля данного ключа из второй темы обновите его новыми 5 записями из первой темы и снова введите для второй темы обновленное значение.
Для этого мне нужно найти второй раздел темы в начале, найти последнюю запись, созданную для данного ключа, и зафиксировать смещение обратно до конца, и после того, как я выполню обновление, снова создадим новую запись длятот же раздел с тем же ключом.Это правильно?Приложение будет использоваться несколькими пользователями, когда они одновременно обновляют записи для одного и того же ключа.
Я также читал о сжатых темах, но не совсем понял значение сжатия, может ли сжатие сохранить толькопоследнюю запись для ключа и сразу удалите все предыдущие записи, когда я создаю новую (таким образом, я могу сохранить ТОЛЬКО последнюю запись для каждого ключа, потому что мне не нужны другие записи), и можете ли вы подсказать мне, каков наилучший способструктурировать мое приложение?