You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2022/09/20 06:54:42 UTC

[GitHub] [pulsar] lwclover opened a new issue, #17731: [Bug] Cannot get replicatedFrom in EntryFilter

lwclover opened a new issue, #17731:
URL: https://github.com/apache/pulsar/issues/17731

   ### Search before asking
   
   - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar.
   
   
   ### Version
   
   linux cenos
   pulsar version 2.10.1
   
   ### Minimal reproduce step
   
   Configure topic level Geo Replicator bidirectional synchronization.
   Implement Entryfilter below:
   ```
       @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;
       }
   ```
   
   
   
   ### What did you expect to see?
   
   I want get replicatedFrom in EntryFilter.
   
   ### What did you see instead?
   
   Cannot get replicatedFrom in EntryFilter
   
   `LOG.info("VDCPreferred has no replicatedFrom field, accept");
   `
   
   ### Anything else?
   
   _No response_
   
   ### Are you willing to submit a PR?
   
   - [X] I'm willing to submit a PR!


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [pulsar] lwclover commented on issue #17731: [Bug] Cannot get replicatedFrom in EntryFilter

Posted by GitBox <gi...@apache.org>.
lwclover commented on issue #17731:
URL: https://github.com/apache/pulsar/issues/17731#issuecomment-1290294254

   > 
   Thank you for your reply.
   
   Pulsar native protocol has no problem. I test the case Using kop.
   I read the code of kop, it does not support entryfilters now.
   
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [pulsar] eolivelli commented on issue #17731: [Bug] Cannot get replicatedFrom in EntryFilter

Posted by GitBox <gi...@apache.org>.
eolivelli commented on issue #17731:
URL: https://github.com/apache/pulsar/issues/17731#issuecomment-1287773715

   Do you know why is this possible?
   The filter has access to low level data.
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [pulsar] lwclover closed issue #17731: [Bug] Cannot get replicatedFrom in EntryFilter

Posted by GitBox <gi...@apache.org>.
lwclover closed issue #17731: [Bug] Cannot get replicatedFrom in EntryFilter
URL: https://github.com/apache/pulsar/issues/17731


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [pulsar] github-actions[bot] commented on issue #17731: [Bug] Cannot get replicatedFrom in EntryFilter

Posted by GitBox <gi...@apache.org>.
github-actions[bot] commented on issue #17731:
URL: https://github.com/apache/pulsar/issues/17731#issuecomment-1287583078

   The issue had no activity for 30 days, mark with Stale label.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org