public void recordOffset(TopicPartition partition, long partitionLastOffset) {
        lastProcessedOffset.put(partition, partitionLastOffset);
    }
@Order(1)
    @Test
    @DisplayName("Tests whether the cache can record offset a single offset")
    void updateOffsetsSinglePartition() {
        final TopicPartition topic1 = new TopicPartition("topic1", 1);

        assertDoesNotThrow(() -> offsetCache.recordOffset(topic1, 1));
        assertDoesNotThrow(() -> offsetCache.recordOffset(topic1, 2));
        assertDoesNotThrow(() -> offsetCache.recordOffset(topic1, 2),
                "The cache should not throw exceptions for duplicate records");
    }