Массовая обработка данных с помощью соединения с потоками кафки приводит к «Пропуску записи для сегмента с истекшим сроком действия»

#java #apache-kafka #apache-kafka-streams Вопрос: При передаче массовых данных через приложение kafka-steams я много раз вижу, как оно регистрирует следующее сообщение... WARN org.apache.kafka.streams.state.internals.AbstractRocksDBSegmentedBytesStore - Skipping record for expired segment. ...и данные,…