У меня есть потоковое приложение с 2 тематическими источниками.одна тема читается как KStream, а другая - как KTable.Я отфильтровываю сообщения из KStream, выполняя операцию соединения на KTable.проблема в том, что через некоторое время (несколько дней) некоторые записи из таблицы KTable исчезают - объединение не работает должным образом.Моя тема KTable определяется компактной политикой.если я перезагружаю потоковое приложение kafka, оно думает, что работает должным образом, поэтому я предполагаю, что оно как-то связано с RocksDB.Пожалуйста, сообщите