Untitled

avatar
unknown
plain_text
a year ago
9.3 kB
6
Indexable
2024-07-02T12:10:29.452Z ERROR 7 --- [044c1085e-0-C-1] o.s.k.l.FallbackBatchErrorHandler        : Records discarded: fraud-issue-alert-0@61

org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void com.moniepoint.casemanagement.service.processing.CaseAlertConsumer.consume(java.util.List<org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.String, java.lang.String>>)' threw exception
	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2957) ~[spring-kafka-3.1.4.jar!/:3.1.4]
	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeBatchOnMessage(KafkaMessageListenerContainer.java:2487) ~[spring-kafka-3.1.4.jar!/:3.1.4]
	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeBatchOnMessageWithRecordsOrList(KafkaMessageListenerContainer.java:2454) ~[spring-kafka-3.1.4.jar!/:3.1.4]
	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.lambda$invokeBatchErrorHandler$44(KafkaMessageListenerContainer.java:2499) ~[spring-kafka-3.1.4.jar!/:3.1.4]
	at org.springframework.kafka.listener.ErrorHandlingUtils.retryBatch(ErrorHandlingUtils.java:141) ~[spring-kafka-3.1.4.jar!/:3.1.4]
	at org.springframework.kafka.listener.FallbackBatchErrorHandler.handleBatch(FallbackBatchErrorHandler.java:152) ~[spring-kafka-3.1.4.jar!/:3.1.4]
	at org.springframework.kafka.listener.FailedBatchProcessor.fallback(FailedBatchProcessor.java:195) ~[spring-kafka-3.1.4.jar!/:3.1.4]
	at org.springframework.kafka.listener.FailedBatchProcessor.handle(FailedBatchProcessor.java:166) ~[spring-kafka-3.1.4.jar!/:3.1.4]
	at org.springframework.kafka.listener.FailedBatchProcessor.doHandle(FailedBatchProcessor.java:157) ~[spring-kafka-3.1.4.jar!/:3.1.4]
	at org.springframework.kafka.listener.DefaultErrorHandler.handleBatch(DefaultErrorHandler.java:176) ~[spring-kafka-3.1.4.jar!/:3.1.4]
	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeBatchErrorHandler(KafkaMessageListenerContainer.java:2497) ~[spring-kafka-3.1.4.jar!/:3.1.4]
	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeBatchListener(KafkaMessageListenerContainer.java:2295) ~[spring-kafka-3.1.4.jar!/:3.1.4]
	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeBatchListener(KafkaMessageListenerContainer.java:2173) ~[spring-kafka-3.1.4.jar!/:3.1.4]
	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2152) ~[spring-kafka-3.1.4.jar!/:3.1.4]
	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1495) ~[spring-kafka-3.1.4.jar!/:3.1.4]
	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1460) ~[spring-kafka-3.1.4.jar!/:3.1.4]
	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1330) ~[spring-kafka-3.1.4.jar!/:3.1.4]
	at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(Unknown Source) ~[na:na]
	at util.TokenAwareRunnable.run(TokenAwareRunnable.java:28) ~[na:na]
	at java.base/java.lang.Thread.run(Unknown Source) ~[na:na]
	Suppressed: org.springframework.kafka.listener.ListenerExecutionFailedException: Restored Stack Trace
		at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:391) ~[spring-kafka-3.1.4.jar!/:3.1.4]
		at org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter.invoke(BatchMessagingMessageListenerAdapter.java:180) ~[spring-kafka-3.1.4.jar!/:3.1.4]
		at org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter.onMessage(BatchMessagingMessageListenerAdapter.java:172) ~[spring-kafka-3.1.4.jar!/:3.1.4]
		at org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter.onMessage(BatchMessagingMessageListenerAdapter.java:61) ~[spring-kafka-3.1.4.jar!/:3.1.4]
		at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeBatchOnMessage(KafkaMessageListenerContainer.java:2473) ~[spring-kafka-3.1.4.jar!/:3.1.4]
Caused by: org.springframework.web.client.HttpServerErrorException: 500 Internal Server Error
	at com.moniepoint.casemanagement.config.interceptors.ResponseHandlerInterceptor.throwAppropriateException(ResponseHandlerInterceptor.java:63) ~[!/:0.0.1-SNAPSHOT]
	at com.moniepoint.casemanagement.config.interceptors.ResponseHandlerInterceptor.intercept(ResponseHandlerInterceptor.java:43) ~[!/:0.0.1-SNAPSHOT]
	at org.springframework.http.client.InterceptingClientHttpRequest$InterceptingRequestExecution.execute(InterceptingClientHttpRequest.java:88) ~[spring-web-6.1.6.jar!/:6.1.6]
	at com.moniepoint.casemanagement.config.interceptors.LoggingInterceptor.intercept(LoggingInterceptor.java:21) ~[!/:0.0.1-SNAPSHOT]
	at org.springframework.http.client.InterceptingClientHttpRequest$InterceptingRequestExecution.execute(InterceptingClientHttpRequest.java:88) ~[spring-web-6.1.6.jar!/:6.1.6]
	at com.moniepoint.casemanagement.config.interceptors.AuthorizationInterceptor.intercept(AuthorizationInterceptor.java:30) ~[!/:0.0.1-SNAPSHOT]
	at org.springframework.http.client.InterceptingClientHttpRequest$InterceptingRequestExecution.execute(InterceptingClientHttpRequest.java:88) ~[spring-web-6.1.6.jar!/:6.1.6]
	at org.springframework.http.client.InterceptingClientHttpRequest.executeInternal(InterceptingClientHttpRequest.java:72) ~[spring-web-6.1.6.jar!/:6.1.6]
	at org.springframework.http.client.AbstractBufferingClientHttpRequest.executeInternal(AbstractBufferingClientHttpRequest.java:48) ~[spring-web-6.1.6.jar!/:6.1.6]
	at org.springframework.http.client.AbstractClientHttpRequest.execute(AbstractClientHttpRequest.java:66) ~[spring-web-6.1.6.jar!/:6.1.6]
	at org.springframework.web.client.DefaultRestClient$DefaultRequestBodyUriSpec.exchangeInternal(DefaultRestClient.java:476) ~[spring-web-6.1.6.jar!/:6.1.6]
	at org.springframework.web.client.DefaultRestClient$DefaultRequestBodyUriSpec.retrieve(DefaultRestClient.java:444) ~[spring-web-6.1.6.jar!/:6.1.6]
	at com.moniepoint.casemanagement.service.zendesk.ZendeskClient.postZendeskTicket(ZendeskClient.java:27) ~[!/:0.0.1-SNAPSHOT]
	at com.moniepoint.casemanagement.service.zendesk.ZendeskService.createZendeskTicket(ZendeskService.java:68) ~[!/:0.0.1-SNAPSHOT]
	at com.moniepoint.casemanagement.service.zendesk.ZendeskService.logZendesk(ZendeskService.java:53) ~[!/:0.0.1-SNAPSHOT]
	at com.moniepoint.casemanagement.service.processing.handlers.ZendeskAutoActionHandler.doHandle(ZendeskAutoActionHandler.java:22) ~[!/:0.0.1-SNAPSHOT]
	at com.moniepoint.casemanagement.service.processing.handlers.ActionHandler.handle(ActionHandler.java:17) ~[!/:0.0.1-SNAPSHOT]
	at com.moniepoint.casemanagement.service.processing.CaseAlertActionHandler.handle(CaseAlertActionHandler.java:26) ~[!/:0.0.1-SNAPSHOT]
	at com.moniepoint.casemanagement.service.processing.CaseProcessor.processCaseAlert(CaseProcessor.java:27) ~[!/:0.0.1-SNAPSHOT]
	at com.moniepoint.casemanagement.service.processing.CaseAlertConsumer.consume(CaseAlertConsumer.java:32) ~[!/:0.0.1-SNAPSHOT]
	at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(Unknown Source) ~[na:na]
	at java.base/java.lang.reflect.Method.invoke(Unknown Source) ~[na:na]
	at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:169) ~[spring-messaging-6.1.6.jar!/:6.1.6]
	at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:119) ~[spring-messaging-6.1.6.jar!/:6.1.6]
	at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:56) ~[spring-kafka-3.1.4.jar!/:3.1.4]
	at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:376) ~[spring-kafka-3.1.4.jar!/:3.1.4]
	at org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter.invoke(BatchMessagingMessageListenerAdapter.java:180) ~[spring-kafka-3.1.4.jar!/:3.1.4]
	at org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter.onMessage(BatchMessagingMessageListenerAdapter.java:172) ~[spring-kafka-3.1.4.jar!/:3.1.4]
	at org.springframework.kafka.listener.adapter.BatchMessagingMessageListenerAdapter.onMessage(BatchMessagingMessageListenerAdapter.java:61) ~[spring-kafka-3.1.4.jar!/:3.1.4]
	at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeBatchOnMessage(KafkaMessageListenerContainer.java:2473) ~[spring-kafka-3.1.4.jar!/:3.1.4]
	... 18 common frames omitted

2024-07-02T12:10:29.453Z DEBUG 7 --- [044c1085e-0-C-1] fkaConsumerFactory$ExtendedKafkaConsumer : [Consumer clientId=consumer-case-management-group-2, groupId=case-management-group] Resuming partitions [fraud-issue-alert-0, fraud-issue-alert-1, fraud-issue-alert-2, fraud-issue-alert-3, fraud-issue-alert-4]
Editor is loading...
Leave a Comment