private Map<String, Object> getValidMetaMap() {
        Map<String, Object> metaMap = new HashMap<>();
        metaCache.forEach((key, value) -> {
            switch (key) {
                case LOG_META_KEY:
                    metaMap.put(key, ElasticLogMeta.decode(value.value()));
                    break;
                case PARTITION_META_KEY:
                    metaMap.put(key, ElasticPartitionMeta.decode(value.value()));
                    break;
                case PRODUCER_SNAPSHOTS_META_KEY:
                    metaMap.put(key, ElasticPartitionProducerSnapshotsMeta.decode(value.value()));
                    break;
                case LEADER_EPOCH_CHECKPOINT_KEY:
                    metaMap.put(key, ElasticLeaderEpochCheckpointMeta.decode(value.value()));
                    break;
                default:
                    metaMap.put(key, value.value().duplicate());
            }
        });
        return metaMap;
    }
Replay meta stream and return a map of meta keyValues. KeyValues will be cached in metaCache.

@return meta keyValues map
core/src/main/scala/kafka/log/streamaspect/MetaStream.java