How to get properties in org.apache.pulsar.broker.intercept.BrokerInterceptor#beforeSendMessage ?

[KMoonSC]

Version

2.7.1

What do you want ?

i want to log some information in Broker before messages send to consumer

What have you done？

i use BrokerInterceptor to do so

here's my BrokerInterceptor:

public class LogBrokerInterceptor implements BrokerInterceptor {
    private static final Logger logger = LoggerFactory.getLogger(LogBrokerInterceptor.class);
    @Override
    public void beforeSendMessage(Subscription subscription, Entry entry, long[] ackSet, PulsarApi.MessageMetadata msgMetadata) {
        List<PulsarApi.KeyValue> properties = msgMetadata.getPropertiesList();
        for (PulsarApi.KeyValue keyValue : properties) {
            logger.info("LogBrokerInterceptor beforeSendMessage. properties key:{} value:{}", keyValue.getKey(), keyValue.getValue());
        }
        logger.info("LogBrokerInterceptor beforeSendMessage. topic:{} subscription:{} sequenceId:{} propertiesSize:{}", subscription.getTopic(), subscription.getName(), msgMetadata.getSequenceId(), properties.size());
    }

and here's my produce test:

PulsarClient client = PulsarClient.builder()
                .serviceUrl("pulsar://localhost:6650")
                .build();
        Producer producer = client.newProducer()
                .topic("public/default/my-topic")
                .create();

        Map<String, String> properties = new HashMap<>();
        properties.put("clientId", "clientId123");
        producer.newMessage()
                .properties(properties)
                .value("data1234".getBytes())
                .send();

What did you expect to see?

the properties i settled wound be logged like this:
"LogBrokerInterceptor beforeSendMessage. properties key:clientId value:clientId123"

What did you see instead?

there's no such log, but this;
"LogBrokerInterceptor beforeSendMessage. topic:xxx subscription:xxx sequenceId:xxx propertiesSize:0"
shows that there is no properties in msgMetadata

Q

so here is the Question:
Am I using the wrong way to get the properties I set to the message ?
If so, how to make it right?

[urdogan0000]

Hi, Can you send broker conf which related brokerInterceptors also pom file for build this interceptor