在EntryFilter中无法获取到相关属性

两个pulsar集群互相同步消息,在EntryFilter中无法获取到replicatedFrom

    @Override
    public FilterResult filterEntry(Entry entry, FilterContext context) {
        MessageMetadata messageMetaData = context.getMsgMetadata();
        if(!messageMetaData.hasReplicatedFrom()) {
            LOG.info("VDCPreferred has no replicatedFrom field, accept");
        }
        LOG.info("VDCPreferred ReplicatedFrom {}, ReplicateTosList {}", messageMetaData.hasReplicatedFrom() ? messageMetaData.getReplicatedFrom() : "none", messageMetaData.getReplicateTosList());
        List<KeyValue> keyValues = messageMetaData.getPropertiesList();
        for(KeyValue kv : keyValues) {
            LOG.info("VDCPreferred key {}, value {}", kv.getKey(), kv.getValue());
        }
        return FilterResult.ACCEPT;
    }