Partition: 0
Offset: 59
Key: ba4b5617-1266-49bf-8381-bb333224e316
Timestamp: 2026-06-26 11:49:53.925
Headers: dlq-attempt-count: 3, dlq-error-class: org.springframework.kafka.listener.ListenerExecutionFailedException, dlq-error-code: UNKNOWN_ERROR, dlq-error-message: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception, dlq-failed-at: 2026-06-26T11:49:53.427987865Z, dlq-original-topic: notification.request, dlq-task-id: ba4b5617-1266-49bf-8381-bb333224e316, kafka_dlt-exception-cause-fqcn: com.fab.ksa.middleware.sitecoreadapter.exception.TemplateNotFoundException, kafka_dlt-exception-fqcn: org.springframework.kafka.listener.ListenerExecutionFailedException, kafka_dlt-exception-message: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception; SMS Template not in DB, kafka_dlt-exception-stacktrace: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:3043)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2950)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2914)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2826)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2663)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2552)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2201)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1555)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1493)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1362)
at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
at java.base/java.lang.Thread.run(Thread.java:1583)
Suppressed: org.springframework.kafka.listener.ListenerExecutionFailedException: Restored Stack Trace
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:490)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2936)
Caused by: com.fab.ksa.middleware.sitecoreadapter.exception.TemplateNotFoundException: SMS Template not in DB
at com.fab.ksa.middleware.sitecoreadapter.client.impl.SitecoreTemplateClientImpl.lambda$fetchFromDatabase$5(SitecoreTemplateClientImpl.java:96)
at java.base/java.util.Optional.orElseThrow(Optional.java:403)
at com.fab.ksa.middleware.sitecoreadapter.client.impl.SitecoreTemplateClientImpl.lambda$fetchFromDatabase$6(SitecoreTemplateClientImpl.java:96)
at reactor.core.publisher.MonoCallable.call(MonoCallable.java:72)
at reactor.core.publisher.FluxSubscribeOnCallable$CallableSubscribeOnSubscription.run(FluxSubscribeOnCallable.java:228)
at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:68)
at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:28)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
... 1 more
Suppressed: java.lang.Exception: #block terminated with an error
at reactor.core.publisher.BlockingSingleSubscriber.blockingGet(BlockingSingleSubscriber.java:104)
at reactor.core.publisher.Mono.block(Mono.java:1779)
at com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(NotificationListener.java:50)
at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
at java.base/java.lang.reflect.Method.invoke(Method.java:580)
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:169)
at org.springframework.kafka.listener.adapter.KotlinAwareInvocableHandlerMethod.doInvoke(KotlinAwareInvocableHandlerMethod.java:45)
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:119)
at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:78)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:475)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2936)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2914)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2826)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2663)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2552)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2201)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1555)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1493)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1362)
at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
... 1 more
, kafka_dlt-original-consumer-group: notification-service-group, kafka_dlt-original-offset: ~, kafka_dlt-original-partition: , kafka_dlt-original-timestamp: �¤�, kafka_dlt-original-timestamp-type: CreateTime, kafka_dlt-original-topic: notification.request
{"envelope":{"eventId":"ba4b5617-1266-49bf-8381-bb333224e316","eventVersion":"1.0","correlationId":"c2207618-9a16-4a5f-87aa-07fcb707b21b","idempotencyKey":"1bbde088-fa58-4722-a12a-6cad67966033","sourceSystem":"CARD_ONBOARDING","channelHint":["SMS"]},"payload":{"eventCode":"OTP_GENERATED","notificationType":"TRANSACTIONAL","requestedChannels":["SMS"],"language":"EN","recipientType":"APPLICANT","customerId":"CID123","recipient":{"mobilePhone":"+966501234567","emailAddress":"customer@email.com"},"templateVariables":[{"key":"otp","value":"775855"},{"key":"expiresInMinutes","value":"5 minutes"}],"attachments":null}}
Partition: 0
Offset: 60
Key: 116feefb-c360-4a0c-a9e6-01a7dd68f8e2
Timestamp: 2026-06-26 11:50:38.296
Headers: dlq-attempt-count: 3, dlq-error-class: org.springframework.kafka.listener.ListenerExecutionFailedException, dlq-error-code: UNKNOWN_ERROR, dlq-error-message: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception, dlq-failed-at: 2026-06-26T11:50:37.803991811Z, dlq-original-topic: notification.request, dlq-task-id: 116feefb-c360-4a0c-a9e6-01a7dd68f8e2, kafka_dlt-exception-cause-fqcn: com.fab.ksa.middleware.sitecoreadapter.exception.TemplateNotFoundException, kafka_dlt-exception-fqcn: org.springframework.kafka.listener.ListenerExecutionFailedException, kafka_dlt-exception-message: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception; SMS Template not in DB, kafka_dlt-exception-stacktrace: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:3043)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2950)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2914)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2826)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2663)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2552)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2201)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1555)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1493)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1362)
at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
at java.base/java.lang.Thread.run(Thread.java:1583)
Suppressed: org.springframework.kafka.listener.ListenerExecutionFailedException: Restored Stack Trace
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:490)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2936)
Caused by: com.fab.ksa.middleware.sitecoreadapter.exception.TemplateNotFoundException: SMS Template not in DB
at com.fab.ksa.middleware.sitecoreadapter.client.impl.SitecoreTemplateClientImpl.lambda$fetchFromDatabase$5(SitecoreTemplateClientImpl.java:96)
at java.base/java.util.Optional.orElseThrow(Optional.java:403)
at com.fab.ksa.middleware.sitecoreadapter.client.impl.SitecoreTemplateClientImpl.lambda$fetchFromDatabase$6(SitecoreTemplateClientImpl.java:96)
at reactor.core.publisher.MonoCallable.call(MonoCallable.java:72)
at reactor.core.publisher.FluxSubscribeOnCallable$CallableSubscribeOnSubscription.run(FluxSubscribeOnCallable.java:228)
at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:68)
at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:28)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
... 1 more
Suppressed: java.lang.Exception: #block terminated with an error
at reactor.core.publisher.BlockingSingleSubscriber.blockingGet(BlockingSingleSubscriber.java:104)
at reactor.core.publisher.Mono.block(Mono.java:1779)
at com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(NotificationListener.java:50)
at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
at java.base/java.lang.reflect.Method.invoke(Method.java:580)
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:169)
at org.springframework.kafka.listener.adapter.KotlinAwareInvocableHandlerMethod.doInvoke(KotlinAwareInvocableHandlerMethod.java:45)
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:119)
at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:78)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:475)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2936)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2914)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2826)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2663)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2552)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2201)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1555)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1493)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1362)
at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
... 1 more
, kafka_dlt-original-consumer-group: notification-service-group, kafka_dlt-original-offset: , kafka_dlt-original-partition: , kafka_dlt-original-timestamp: ��d�, kafka_dlt-original-timestamp-type: CreateTime, kafka_dlt-original-topic: notification.request
{"envelope":{"eventId":"116feefb-c360-4a0c-a9e6-01a7dd68f8e2","eventVersion":"1.0","correlationId":"123","idempotencyKey":"530e0220-e24b-51d5-a716-445655340020","sourceSystem":"CARD_ONBOARDING","channelHint":["SMS"]},"payload":{"eventCode":"OTP_GENERATED","notificationType":"TRANSACTIONAL","requestedChannels":["SMS"],"language":"EN","recipientType":"APPLICANT","customerId":"CID123","recipient":{"mobilePhone":"+966501234567","emailAddress":"customer@email.com"},"templateVariables":[{"key":"otp","value":"663559"},{"key":"expiresInMinutes","value":"5 minutes"}],"attachments":null}}
Partition: 0
Offset: 61
Key: 3a8b37c6-d7bd-4ad1-9026-af3bbefded69
Timestamp: 2026-06-26 11:54:48.431
Headers: dlq-attempt-count: 3, dlq-error-class: org.springframework.kafka.listener.ListenerExecutionFailedException, dlq-error-code: UNKNOWN_ERROR, dlq-error-message: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception, dlq-failed-at: 2026-06-26T11:54:47.426605047Z, dlq-original-topic: notification.request, dlq-task-id: 3a8b37c6-d7bd-4ad1-9026-af3bbefded69, kafka_dlt-exception-cause-fqcn: com.fab.ksa.middleware.sitecoreadapter.exception.TemplateNotFoundException, kafka_dlt-exception-fqcn: org.springframework.kafka.listener.ListenerExecutionFailedException, kafka_dlt-exception-message: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception; SMS Template not in DB, kafka_dlt-exception-stacktrace: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:3043)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2950)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2914)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2826)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2663)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2552)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2201)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1555)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1493)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1362)
at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
at java.base/java.lang.Thread.run(Thread.java:1583)
Suppressed: org.springframework.kafka.listener.ListenerExecutionFailedException: Restored Stack Trace
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:490)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2936)
Caused by: com.fab.ksa.middleware.sitecoreadapter.exception.TemplateNotFoundException: SMS Template not in DB
at com.fab.ksa.middleware.sitecoreadapter.client.impl.SitecoreTemplateClientImpl.lambda$fetchFromDatabase$5(SitecoreTemplateClientImpl.java:96)
at java.base/java.util.Optional.orElseThrow(Optional.java:403)
at com.fab.ksa.middleware.sitecoreadapter.client.impl.SitecoreTemplateClientImpl.lambda$fetchFromDatabase$6(SitecoreTemplateClientImpl.java:96)
at reactor.core.publisher.MonoCallable.call(MonoCallable.java:72)
at reactor.core.publisher.FluxSubscribeOnCallable$CallableSubscribeOnSubscription.run(FluxSubscribeOnCallable.java:228)
at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:68)
at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:28)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
... 1 more
Suppressed: java.lang.Exception: #block terminated with an error
at reactor.core.publisher.BlockingSingleSubscriber.blockingGet(BlockingSingleSubscriber.java:104)
at reactor.core.publisher.Mono.block(Mono.java:1779)
at com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(NotificationListener.java:50)
at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
at java.base/java.lang.reflect.Method.invoke(Method.java:580)
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:169)
at org.springframework.kafka.listener.adapter.KotlinAwareInvocableHandlerMethod.doInvoke(KotlinAwareInvocableHandlerMethod.java:45)
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:119)
at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:78)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:475)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2936)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2914)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2826)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2663)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2552)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2201)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1555)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1493)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1362)
at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
... 1 more
, kafka_dlt-original-consumer-group: notification-service-group, kafka_dlt-original-offset: �, kafka_dlt-original-partition: , kafka_dlt-original-timestamp: ��^�, kafka_dlt-original-timestamp-type: CreateTime, kafka_dlt-original-topic: notification.request
{"envelope":{"eventId":"3a8b37c6-d7bd-4ad1-9026-af3bbefded69","eventVersion":"1.0","correlationId":"e3213352-2a00-43dc-914a-d7f1762bc2f4","idempotencyKey":"9d712dbd-b6b7-4dd2-aecb-be77e0ecbfaa","sourceSystem":"CARD_ONBOARDING","channelHint":["SMS"]},"payload":{"eventCode":"OTP_GENERATED","notificationType":"TRANSACTIONAL","requestedChannels":["SMS"],"language":"EN","recipientType":"APPLICANT","customerId":"CID123","recipient":{"mobilePhone":"+966501234567","emailAddress":"customer@email.com"},"templateVariables":[{"key":"otp","value":"017354"},{"key":"expiresInMinutes","value":"5 minutes"}],"attachments":null}}
Partition: 0
Offset: 62
Key: 8bbed1b4-c52c-4305-a2c0-02bc38e671c5
Timestamp: 2026-06-26 11:54:57.434
Headers: dlq-attempt-count: 3, dlq-error-class: org.springframework.kafka.listener.ListenerExecutionFailedException, dlq-error-code: UNKNOWN_ERROR, dlq-error-message: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception, dlq-failed-at: 2026-06-26T11:54:57.024847720Z, dlq-original-topic: notification.request, dlq-task-id: 8bbed1b4-c52c-4305-a2c0-02bc38e671c5, kafka_dlt-exception-cause-fqcn: com.fab.ksa.middleware.sitecoreadapter.exception.TemplateNotFoundException, kafka_dlt-exception-fqcn: org.springframework.kafka.listener.ListenerExecutionFailedException, kafka_dlt-exception-message: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception; SMS Template not in DB, kafka_dlt-exception-stacktrace: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:3043)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2950)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2914)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2826)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2663)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2552)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2201)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1555)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1493)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1362)
at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
at java.base/java.lang.Thread.run(Thread.java:1583)
Suppressed: org.springframework.kafka.listener.ListenerExecutionFailedException: Restored Stack Trace
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:490)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2936)
Caused by: com.fab.ksa.middleware.sitecoreadapter.exception.TemplateNotFoundException: SMS Template not in DB
at com.fab.ksa.middleware.sitecoreadapter.client.impl.SitecoreTemplateClientImpl.lambda$fetchFromDatabase$5(SitecoreTemplateClientImpl.java:96)
at java.base/java.util.Optional.orElseThrow(Optional.java:403)
at com.fab.ksa.middleware.sitecoreadapter.client.impl.SitecoreTemplateClientImpl.lambda$fetchFromDatabase$6(SitecoreTemplateClientImpl.java:96)
at reactor.core.publisher.MonoCallable.call(MonoCallable.java:72)
at reactor.core.publisher.FluxSubscribeOnCallable$CallableSubscribeOnSubscription.run(FluxSubscribeOnCallable.java:228)
at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:68)
at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:28)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
... 1 more
Suppressed: java.lang.Exception: #block terminated with an error
at reactor.core.publisher.BlockingSingleSubscriber.blockingGet(BlockingSingleSubscriber.java:104)
at reactor.core.publisher.Mono.block(Mono.java:1779)
at com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(NotificationListener.java:50)
at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
at java.base/java.lang.reflect.Method.invoke(Method.java:580)
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:169)
at org.springframework.kafka.listener.adapter.KotlinAwareInvocableHandlerMethod.doInvoke(KotlinAwareInvocableHandlerMethod.java:45)
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:119)
at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:78)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:475)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2936)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2914)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2826)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2663)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2552)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2201)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1555)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1493)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1362)
at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
... 1 more
, kafka_dlt-original-consumer-group: notification-service-group, kafka_dlt-original-offset: �, kafka_dlt-original-partition: , kafka_dlt-original-timestamp: ��, kafka_dlt-original-timestamp-type: CreateTime, kafka_dlt-original-topic: notification.request
{"envelope":{"eventId":"8bbed1b4-c52c-4305-a2c0-02bc38e671c5","eventVersion":"1.0","correlationId":"3509f265-66a2-4086-bff6-fb40e0f5fa1f","idempotencyKey":"137f8ee9-b087-4454-80da-800573222a81","sourceSystem":"CARD_ONBOARDING","channelHint":["SMS"]},"payload":{"eventCode":"OTP_GENERATED","notificationType":"TRANSACTIONAL","requestedChannels":["SMS"],"language":"EN","recipientType":"APPLICANT","customerId":"CID123","recipient":{"mobilePhone":"+966501234567","emailAddress":"customer@email.com"},"templateVariables":[{"key":"otp","value":"758916"},{"key":"expiresInMinutes","value":"5 minutes"}],"attachments":null}}
Partition: 0
Offset: 63
Key: 4a866cae-2833-45d4-a60c-f6f89fe880d8
Timestamp: 2026-06-26 11:55:05.532
Headers: dlq-attempt-count: 3, dlq-error-class: org.springframework.kafka.listener.ListenerExecutionFailedException, dlq-error-code: UNKNOWN_ERROR, dlq-error-message: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception, dlq-failed-at: 2026-06-26T11:55:05.126889748Z, dlq-original-topic: notification.request, dlq-task-id: 4a866cae-2833-45d4-a60c-f6f89fe880d8, kafka_dlt-exception-cause-fqcn: com.fab.ksa.middleware.sitecoreadapter.exception.TemplateNotFoundException, kafka_dlt-exception-fqcn: org.springframework.kafka.listener.ListenerExecutionFailedException, kafka_dlt-exception-message: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception; SMS Template not in DB, kafka_dlt-exception-stacktrace: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:3043)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2950)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2914)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2826)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2663)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2552)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2201)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1555)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1493)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1362)
at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
at java.base/java.lang.Thread.run(Thread.java:1583)
Suppressed: org.springframework.kafka.listener.ListenerExecutionFailedException: Restored Stack Trace
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:490)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2936)
Caused by: com.fab.ksa.middleware.sitecoreadapter.exception.TemplateNotFoundException: SMS Template not in DB
at com.fab.ksa.middleware.sitecoreadapter.client.impl.SitecoreTemplateClientImpl.lambda$fetchFromDatabase$5(SitecoreTemplateClientImpl.java:96)
at java.base/java.util.Optional.orElseThrow(Optional.java:403)
at com.fab.ksa.middleware.sitecoreadapter.client.impl.SitecoreTemplateClientImpl.lambda$fetchFromDatabase$6(SitecoreTemplateClientImpl.java:96)
at reactor.core.publisher.MonoCallable.call(MonoCallable.java:72)
at reactor.core.publisher.FluxSubscribeOnCallable$CallableSubscribeOnSubscription.run(FluxSubscribeOnCallable.java:228)
at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:68)
at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:28)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
... 1 more
Suppressed: java.lang.Exception: #block terminated with an error
at reactor.core.publisher.BlockingSingleSubscriber.blockingGet(BlockingSingleSubscriber.java:104)
at reactor.core.publisher.Mono.block(Mono.java:1779)
at com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(NotificationListener.java:50)
at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
at java.base/java.lang.reflect.Method.invoke(Method.java:580)
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:169)
at org.springframework.kafka.listener.adapter.KotlinAwareInvocableHandlerMethod.doInvoke(KotlinAwareInvocableHandlerMethod.java:45)
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:119)
at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:78)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:475)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2936)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2914)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2826)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2663)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2552)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2201)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1555)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1493)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1362)
at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
... 1 more
, kafka_dlt-original-consumer-group: notification-service-group, kafka_dlt-original-offset: �, kafka_dlt-original-partition: , kafka_dlt-original-timestamp: ���, kafka_dlt-original-timestamp-type: CreateTime, kafka_dlt-original-topic: notification.request
{"envelope":{"eventId":"4a866cae-2833-45d4-a60c-f6f89fe880d8","eventVersion":"1.0","correlationId":"bb919e5e-b531-44ed-9497-b867c809a794","idempotencyKey":"3aa303ef-3e61-40c6-8ad5-5b179294f955","sourceSystem":"CARD_ONBOARDING","channelHint":["SMS"]},"payload":{"eventCode":"OTP_GENERATED","notificationType":"TRANSACTIONAL","requestedChannels":["SMS"],"language":"EN","recipientType":"APPLICANT","customerId":"CID123","recipient":{"mobilePhone":"+966501234567","emailAddress":"customer@email.com"},"templateVariables":[{"key":"otp","value":"458180"},{"key":"expiresInMinutes","value":"5 minutes"}],"attachments":null}}
Partition: 0
Offset: 64
Key: 28ec2775-b498-4707-a57a-4b081ce0bed9
Timestamp: 2026-06-26 11:55:13.447
Headers: dlq-attempt-count: 3, dlq-error-class: org.springframework.kafka.listener.ListenerExecutionFailedException, dlq-error-code: UNKNOWN_ERROR, dlq-error-message: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception, dlq-failed-at: 2026-06-26T11:55:13.028291785Z, dlq-original-topic: notification.request, dlq-task-id: 28ec2775-b498-4707-a57a-4b081ce0bed9, kafka_dlt-exception-cause-fqcn: com.fab.ksa.middleware.sitecoreadapter.exception.TemplateNotFoundException, kafka_dlt-exception-fqcn: org.springframework.kafka.listener.ListenerExecutionFailedException, kafka_dlt-exception-message: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception; SMS Template not in DB, kafka_dlt-exception-stacktrace: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:3043)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2950)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2914)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2826)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2663)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2552)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2201)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1555)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1493)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1362)
at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
at java.base/java.lang.Thread.run(Thread.java:1583)
Suppressed: org.springframework.kafka.listener.ListenerExecutionFailedException: Restored Stack Trace
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:490)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2936)
Caused by: com.fab.ksa.middleware.sitecoreadapter.exception.TemplateNotFoundException: SMS Template not in DB
at com.fab.ksa.middleware.sitecoreadapter.client.impl.SitecoreTemplateClientImpl.lambda$fetchFromDatabase$5(SitecoreTemplateClientImpl.java:96)
at java.base/java.util.Optional.orElseThrow(Optional.java:403)
at com.fab.ksa.middleware.sitecoreadapter.client.impl.SitecoreTemplateClientImpl.lambda$fetchFromDatabase$6(SitecoreTemplateClientImpl.java:96)
at reactor.core.publisher.MonoCallable.call(MonoCallable.java:72)
at reactor.core.publisher.FluxSubscribeOnCallable$CallableSubscribeOnSubscription.run(FluxSubscribeOnCallable.java:228)
at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:68)
at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:28)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
... 1 more
Suppressed: java.lang.Exception: #block terminated with an error
at reactor.core.publisher.BlockingSingleSubscriber.blockingGet(BlockingSingleSubscriber.java:104)
at reactor.core.publisher.Mono.block(Mono.java:1779)
at com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(NotificationListener.java:50)
at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
at java.base/java.lang.reflect.Method.invoke(Method.java:580)
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:169)
at org.springframework.kafka.listener.adapter.KotlinAwareInvocableHandlerMethod.doInvoke(KotlinAwareInvocableHandlerMethod.java:45)
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:119)
at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:78)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:475)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2936)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2914)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2826)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2663)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2552)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2201)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1555)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1493)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1362)
at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
... 1 more
, kafka_dlt-original-consumer-group: notification-service-group, kafka_dlt-original-offset: �, kafka_dlt-original-partition: , kafka_dlt-original-timestamp: �ǭ�, kafka_dlt-original-timestamp-type: CreateTime, kafka_dlt-original-topic: notification.request
{"envelope":{"eventId":"28ec2775-b498-4707-a57a-4b081ce0bed9","eventVersion":"1.0","correlationId":"ad877453-42e9-448b-a2b0-a290d1642cd0","idempotencyKey":"e45e3c71-031d-491c-837c-70f0dbf9c3b4","sourceSystem":"CARD_ONBOARDING","channelHint":["SMS"]},"payload":{"eventCode":"OTP_GENERATED","notificationType":"TRANSACTIONAL","requestedChannels":["SMS"],"language":"EN","recipientType":"APPLICANT","customerId":"CID123","recipient":{"mobilePhone":"+966501234567","emailAddress":"customer@email.com"},"templateVariables":[{"key":"otp","value":"406492"},{"key":"expiresInMinutes","value":"5 minutes"}],"attachments":null}}
Partition: 0
Offset: 65
Key: 77e8e186-3797-433c-afe0-1532781c26e7
Timestamp: 2026-06-26 11:55:23.247
Headers: dlq-attempt-count: 3, dlq-error-class: org.springframework.kafka.listener.ListenerExecutionFailedException, dlq-error-code: UNKNOWN_ERROR, dlq-error-message: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception, dlq-failed-at: 2026-06-26T11:55:22.826219803Z, dlq-original-topic: notification.request, dlq-task-id: 77e8e186-3797-433c-afe0-1532781c26e7, kafka_dlt-exception-cause-fqcn: com.fab.ksa.middleware.sitecoreadapter.exception.TemplateNotFoundException, kafka_dlt-exception-fqcn: org.springframework.kafka.listener.ListenerExecutionFailedException, kafka_dlt-exception-message: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception; SMS Template not in DB, kafka_dlt-exception-stacktrace: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:3043)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2950)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2914)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2826)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2663)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2552)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2201)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1555)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1493)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1362)
at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
at java.base/java.lang.Thread.run(Thread.java:1583)
Suppressed: org.springframework.kafka.listener.ListenerExecutionFailedException: Restored Stack Trace
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:490)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2936)
Caused by: com.fab.ksa.middleware.sitecoreadapter.exception.TemplateNotFoundException: SMS Template not in DB
at com.fab.ksa.middleware.sitecoreadapter.client.impl.SitecoreTemplateClientImpl.lambda$fetchFromDatabase$5(SitecoreTemplateClientImpl.java:96)
at java.base/java.util.Optional.orElseThrow(Optional.java:403)
at com.fab.ksa.middleware.sitecoreadapter.client.impl.SitecoreTemplateClientImpl.lambda$fetchFromDatabase$6(SitecoreTemplateClientImpl.java:96)
at reactor.core.publisher.MonoCallable.call(MonoCallable.java:72)
at reactor.core.publisher.FluxSubscribeOnCallable$CallableSubscribeOnSubscription.run(FluxSubscribeOnCallable.java:228)
at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:68)
at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:28)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
... 1 more
Suppressed: java.lang.Exception: #block terminated with an error
at reactor.core.publisher.BlockingSingleSubscriber.blockingGet(BlockingSingleSubscriber.java:104)
at reactor.core.publisher.Mono.block(Mono.java:1779)
at com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(NotificationListener.java:50)
at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
at java.base/java.lang.reflect.Method.invoke(Method.java:580)
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:169)
at org.springframework.kafka.listener.adapter.KotlinAwareInvocableHandlerMethod.doInvoke(KotlinAwareInvocableHandlerMethod.java:45)
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:119)
at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:78)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:475)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2936)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2914)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2826)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2663)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2552)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2201)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1555)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1493)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1362)
at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
... 1 more
, kafka_dlt-original-consumer-group: notification-service-group, kafka_dlt-original-offset: �, kafka_dlt-original-partition: , kafka_dlt-original-timestamp: ����, kafka_dlt-original-timestamp-type: CreateTime, kafka_dlt-original-topic: notification.request
{"envelope":{"eventId":"77e8e186-3797-433c-afe0-1532781c26e7","eventVersion":"1.0","correlationId":"28e1170c-ab5a-42dc-a580-49f6c12f02f1","idempotencyKey":"55e63436-cb68-45a8-94bf-d99ed0291051","sourceSystem":"CARD_ONBOARDING","channelHint":["SMS"]},"payload":{"eventCode":"OTP_GENERATED","notificationType":"TRANSACTIONAL","requestedChannels":["SMS"],"language":"EN","recipientType":"APPLICANT","customerId":"CID123","recipient":{"mobilePhone":"+966501234567","emailAddress":"customer@email.com"},"templateVariables":[{"key":"otp","value":"744837"},{"key":"expiresInMinutes","value":"5 minutes"}],"attachments":null}}
Partition: 0
Offset: 66
Key: e2cb9a6a-9ea8-4940-a790-8b9004e87bd2
Timestamp: 2026-06-26 11:55:31.279
Headers: dlq-attempt-count: 3, dlq-error-class: org.springframework.kafka.listener.ListenerExecutionFailedException, dlq-error-code: UNKNOWN_ERROR, dlq-error-message: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception, dlq-failed-at: 2026-06-26T11:55:30.786709293Z, dlq-original-topic: notification.request, dlq-task-id: e2cb9a6a-9ea8-4940-a790-8b9004e87bd2, kafka_dlt-exception-cause-fqcn: com.fab.ksa.middleware.sitecoreadapter.exception.TemplateNotFoundException, kafka_dlt-exception-fqcn: org.springframework.kafka.listener.ListenerExecutionFailedException, kafka_dlt-exception-message: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception; SMS Template not in DB, kafka_dlt-exception-stacktrace: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(com.fab.ksa.middleware.notificationrequest.kafka.dto.NotificationRequestedEvent,java.lang.String,org.springframework.kafka.support.Acknowledgment)' threw exception
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:3043)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2950)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2914)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2826)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2663)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2552)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2201)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1555)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1493)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1362)
at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
at java.base/java.lang.Thread.run(Thread.java:1583)
Suppressed: org.springframework.kafka.listener.ListenerExecutionFailedException: Restored Stack Trace
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:490)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2936)
Caused by: com.fab.ksa.middleware.sitecoreadapter.exception.TemplateNotFoundException: SMS Template not in DB
at com.fab.ksa.middleware.sitecoreadapter.client.impl.SitecoreTemplateClientImpl.lambda$fetchFromDatabase$5(SitecoreTemplateClientImpl.java:96)
at java.base/java.util.Optional.orElseThrow(Optional.java:403)
at com.fab.ksa.middleware.sitecoreadapter.client.impl.SitecoreTemplateClientImpl.lambda$fetchFromDatabase$6(SitecoreTemplateClientImpl.java:96)
at reactor.core.publisher.MonoCallable.call(MonoCallable.java:72)
at reactor.core.publisher.FluxSubscribeOnCallable$CallableSubscribeOnSubscription.run(FluxSubscribeOnCallable.java:228)
at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:68)
at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:28)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
... 1 more
Suppressed: java.lang.Exception: #block terminated with an error
at reactor.core.publisher.BlockingSingleSubscriber.blockingGet(BlockingSingleSubscriber.java:104)
at reactor.core.publisher.Mono.block(Mono.java:1779)
at com.fab.ksa.middleware.notificationrequest.kafka.NotificationListener.consume(NotificationListener.java:50)
at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
at java.base/java.lang.reflect.Method.invoke(Method.java:580)
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:169)
at org.springframework.kafka.listener.adapter.KotlinAwareInvocableHandlerMethod.doInvoke(KotlinAwareInvocableHandlerMethod.java:45)
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:119)
at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:78)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:475)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invoke(MessagingMessageListenerAdapter.java:421)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:85)
at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:50)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2936)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2914)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2826)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2663)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2552)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2201)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1555)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1493)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1362)
at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
... 1 more
, kafka_dlt-original-consumer-group: notification-service-group, kafka_dlt-original-offset: �, kafka_dlt-original-partition: , kafka_dlt-original-timestamp: �ȡ�, kafka_dlt-original-timestamp-type: CreateTime, kafka_dlt-original-topic: notification.request
{"envelope":{"eventId":"e2cb9a6a-9ea8-4940-a790-8b9004e87bd2","eventVersion":"1.0","correlationId":"1ee1c48d-3ebd-4c9e-a1f3-00e0dc0e0a02","idempotencyKey":"3e0cf3a7-68bb-439b-a373-2ac65aed5150","sourceSystem":"CARD_ONBOARDING","channelHint":["SMS"]},"payload":{"eventCode":"OTP_GENERATED","notificationType":"TRANSACTIONAL","requestedChannels":["SMS"],"language":"EN","recipientType":"APPLICANT","customerId":"CID123","recipient":{"mobilePhone":"+966501234567","emailAddress":null},"templateVariables":[{"key":"otp","value":"16250822"},{"key":"expiresInMinutes","value":"3 minutes"}],"attachments":null}}
