properties.yaml
consumer:
enableDql: true
dlqName: test.dlq
autoCommitOnError: true
autoCommitOffset: true
deliveryAttemptHeader: 1000
maxAttempts: 1000
backOffMaxInterval: 3000
backOffInitialInterval: 3000
backoffMultiplier: 3.0
defaultRetryable: true
public Consumer<Message<T>> test() {
log.info("received message");
return message -> {
log.debug("Incoming msg:: {} ", message);
log.info("Received the msg for {} ", message.getPayload());
MsgMetaInfo msgMetaInfo = getMsgMetaInfo(message.getPayload(), message.getHeaders());
if (null != message.getHeaders().get("test")) {
//
}
testService.processMessage(message.getPayload(), msgMetaInfo);
};
}
Note : testService.processMessage throwing exception and trying 3 times only
once consumer failed to process the message I am not able to retry it more than 3 times and message are not going to deadletter queue even
Comment From: wilkinsona
Thanks for the report. Unforuntately, it's not clear to me how it relates to Spring Boot. Spring Boot will not read a properties.yaml file by default and its contents don't look like Spring Boot configuration properties. Can you please explain why you have opened a Spring Boot issue for your problem? What do you think can be done in Spring Boot to fix it?
Comment From: rjadiya
My bad, Its an application.yaml file only , wanted to raise a suggest request but raise as a bug , Apologies! I will close this here.