wallezhang commented on issue #6730:
URL: https://github.com/apache/skywalking/issues/6730#issuecomment-817740462
> @wallezhang Could you please share the way that you get the message trace?
```
ConsumerBuilder<?> builder = pulsarClient.newConsumer(getSchema(holder));
builder.consumerName("consumer-" + name)
.subscriptionName(subscriptionName)
.subscriptionType(holder.getAnnotation().subscriptionType())
.messageListener((consumer, msg) -> {
try {
final Method method = holder.getHandler();
log.info("on message. data:{}", msg.getValue());
method.setAccessible(true);
method.invoke(holder.getBean(), msg.getValue());
consumer.acknowledge(msg);
} catch (Exception e) {
e.printStackTrace();
consumer.negativeAcknowledge(msg);
exceptionEmitter.onNext(new FailedMessage(e,
consumer, msg));
}
});
return builder.subscribe();
```
Log In message listener can not get message trace, log output: *****TID:
N/A*****
--
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.
For queries about this service, please contact Infrastructure at:
[email protected]
