kafka_dlt-exception-cause-fqcn: org.springframework.dao.QueryTimeoutException, kafka_dlt-exception-fqcn: org.springframework.kafka.listener.ListenerExecutionFailedException, kafka_dlt-exception-message: Listener method 'public void org.globalim.gimserver.consumer.kafka.FriendMessageConsumer.listen(java.lang.String)' threw exception; Redis command timed out, kafka_dlt-exception-stacktrace: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void org.globalim.gimserver.consumer.kafka.FriendMessageConsumer.listen(java.lang.String)' threw exception
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2989)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2896)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2860)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2772)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2609)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2498)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2149)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1525)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1463)
at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1332)
at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1804)
at java.base/java.lang.Thread.run(Thread.java:840)
Suppressed: org.springframework.kafka.listener.ListenerExecutionFailedException: Restored Stack Trace
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:489)
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:2882)
Caused by: org.springframework.dao.QueryTimeoutException: Redis command timed out
at org.springframework.data.redis.connection.lettuce.LettuceExceptionConverter.convert(LettuceExceptionConverter.java:68)
at org.springframework.data.redis.connection.lettuce.LettuceExceptionConverter.convert(LettuceExceptionConverter.java:41)
at org.springframework.data.redis.PassThroughExceptionTranslationStrategy.translate(PassThroughExceptionTranslationStrategy.java:40)
at org.springframework.data.redis.FallbackExceptionTranslationStrategy.translate(FallbackExceptionTranslationStrategy.java:38)
at org.springframework.data.redis.connection.lettuce.LettuceConnection.convertLettuceAccessException(LettuceConnection.java:310)
at org.springframework.data.redis.connection.lettuce.LettuceConnection.await(LettuceConnection.java:1012)
at org.springframework.data.redis.connection.lettuce.LettuceConnection.lambda$doInvoke$3(LettuceConnection.java:447)
at org.springframework.data.redis.connection.lettuce.LettuceInvoker$Synchronizer.invoke(LettuceInvoker.java:673)
at org.springframework.data.redis.connection.lettuce.LettuceInvoker$DefaultSingleInvocationSpec.getOrElse(LettuceInvoker.java:598)
at org.springframework.data.redis.connection.lettuce.LettuceInvoker$SingleInvocationSpec.orElse(LettuceInvoker.java:385)
at org.springframework.data.redis.connection.lettuce.LettuceStringCommands.set(LettuceStringCommands.java:115)
at org.springframework.data.redis.connection.DefaultedRedisConnection.set(DefaultedRedisConnection.java:326)
at org.springframework.data.redis.connection.DefaultStringRedisConnection.set(DefaultStringRedisConnection.java:770)
at org.springframework.data.redis.core.DefaultValueOperations.lambda$setIfAbsent$17(DefaultValueOperations.java:226)
at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:411)
at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:378)
at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:117)
at org.springframework.data.redis.core.DefaultValueOperations.setIfAbsent(DefaultValueOperations.java:226)
at org.globalim.gimserver.service.idempotent.IdempotentService.tryAcquire(IdempotentService.java:36)
at org.globalim.gimserver.consumer.kafka.FriendMessageConsumer.listen(FriendMessageConsumer.java:57)
at jdk.internal.reflect.GeneratedMethodAccessor1595.invoke(Unknown Source)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:569)
at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:359)
at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:196)
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163)
at org.springframework.aop.aspectj.MethodInvocationProceedingJoinPoint.proceed(MethodInvocationProceedingJoinPoint.java:89)
at org.globalim.gimserver.aop.KafkaMessageConsumerAdvice.logExecutionTime(KafkaMessageConsumerAdvice.java:43)
at jdk.internal.reflect.GeneratedMethodAccessor138.invoke(Unknown Source)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:569)
at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethodWithGivenArgs(AbstractAspectJAdvice.java:638)
at org.springframework.aop.aspectj.AbstractAspectJAdvice.invokeAdviceMethod(AbstractAspectJAdvice.java:628)
at org.springframework.aop.aspectj.AspectJAroundAdvice.invoke(AspectJAroundAdvice.java:71)
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:184)
at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:97)
at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:184)
at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:727)
at org.globalim.gimserver.consumer.kafka.FriendMessageConsumer$$SpringCGLIB$$0.listen(<generated>)
at jdk.internal.reflect.GeneratedMethodAccessor1595.invoke(Unknown Source)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:569)
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:71)
at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:474)
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:2882)
... 10 more
Caused by: io.lettuce.core.RedisCommandTimeoutException: Command timed out after 3 second(s)
at io.lettuce.core.internal.ExceptionFactory.createTimeoutException(ExceptionFactory.java:63)
at io.lettuce.core.internal.Futures.awaitOrCancel(Futures.java:233)
at io.lettuce.core.LettuceFutures.awaitOrCancel(LettuceFutures.java:59)
at org.springframework.data.redis.connection.lettuce.LettuceConnection.await(LettuceConnection.java:1010)
... 55 more
, kafka_dlt-original-consumer-group: gim-message-group, kafka_dlt-original-offset: .�, kafka_dlt-original-partition: , kafka_dlt-original-timestamp: ��l�, kafka_dlt-original-timestamp-type: CreateTime, kafka_dlt-original-topic: GIM_SEND_FD_MSG, traceId: 13bf204e8a9e42d4b20746bf4ded2bdd
{"contentType":6,"fid":"1773311603025884","msgTemp":{"channelType":1,"contentType":6,"fid":"1773311603025884","id":549610,"payload":"{\"bucket\":\"tio-test-2\",\"createUserId\":23295,\"extParam\":\"{\\\"coverHeight\\\":325,\\\"coverUrl\\\":\\\"minio@tio-test-2@image@f6f66833e37205409f8b9487e1abbd2a@150@325.jpg\\\",\\\"coverWidth\\\":150,\\\"duration\\\":0,\\\"ext\\\":\\\"image\\\",\\\"height\\\":325,\\\"name\\\":\\\"Screenshot_20260312_183303_com.tencent.mm.jpg\\\",\\\"size\\\":184937,\\\"width\\\":150}\",\"fileKey\":\"minio@tio-test-2@image@7bdceeb7298b54912319ba09ec705d6e@150@325.jpg\",\"fileMd5\":\"7bdceeb7298b54912319ba09ec705d6e\",\"fileMimeType\":\"6\",\"fileName\":\"Screenshot_20260312_183303_com.tencent.mm.jpg\",\"fileSize\":184937,\"fileSuffix\":\"jpg\",\"fileUseType\":0,\"id\":73851,\"params\":{},\"storageType\":1}","time":1773311651055},"operBizData":"","sysFlag":0,"text":"{\"bucket\":\"tio-test-2\",\"createUserId\":23295,\"extParam\":\"{\\\"coverHeight\\\":325,\\\"coverUrl\\\":\\\"minio@tio-test-2@image@f6f66833e37205409f8b9487e1abbd2a@150@325.jpg\\\",\\\"coverWidth\\\":150,\\\"duration\\\":0,\\\"ext\\\":\\\"image\\\",\\\"height\\\":325,\\\"name\\\":\\\"Screenshot_20260312_183303_com.tencent.mm.jpg\\\",\\\"size\\\":184937,\\\"width\\\":150}\",\"fileKey\":\"minio@tio-test-2@image@7bdceeb7298b54912319ba09ec705d6e@150@325.jpg\",\"fileMd5\":\"7bdceeb7298b54912319ba09ec705d6e\",\"fileMimeType\":\"6\",\"fileName\":\"Screenshot_20260312_183303_com.tencent.mm.jpg\",\"fileSize\":184937,\"fileSuffix\":\"jpg\",\"fileUseType\":0,\"id\":73851,\"params\":{},\"storageType\":1}","toUid":22008,"traceId":"13bf204e8a9e42d4b20746bf4ded2bdd","uid":23295}
