GitHub user KMoonSC edited a discussion: How to get properties in
org.apache.pulsar.broker.intercept.BrokerInterceptor#beforeSendMessage ?
### 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?
GitHub link: https://github.com/apache/pulsar/discussions/20322
----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: [email protected]
