private static Predicate<LocalTieredStorageEvent> matches(final TopicPartition topicPartition) {
        return event -> event.getTopicPartition().equals(topicPartition);
    }
Subscribes to the events generated by the given {@link LocalTieredStorage}.
Note there is no check performed against multiple subscriptions on the same storage.

@param storage The {@link LocalTieredStorage} to subscribe to.
storage/src/test/java/org/apache/kafka/server/log/remote/storage/LocalTieredStorageHistory.java