Kafdrop: Topic: look-algorithm-topic-dlt: Messages

Topic Messages: look-algorithm-topic-dlt

Partition: 0 Offset: 81 Key: empty Timestamp: 2026-06-06 03:55:39.756 Headers: kafka_dlt-exception-cause-fqcn: java.lang.NumberFormatException, kafka_dlt-exception-fqcn: org.springframework.kafka.listener.ListenerExecutionFailedException, kafka_dlt-exception-message: Listener method 'public void ar.com.branded.ms_look.look.adapter.in.kafka.LookAlgorithmKafkaAdapter.listen(java.lang.String)' threw exception; For input string: "", kafka_dlt-exception-stacktrace: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void ar.com.branded.ms_look.look.adapter.in.kafka.LookAlgorithmKafkaAdapter.listen(java.lang.String)' threw exception at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:2994) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:2901) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:2865) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:2777) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:2614) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:2503) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:2152) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeIfHaveRecords(KafkaMessageListenerContainer.java:1528) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1466) at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:1335) at java.base/java.util.concurrent.CompletableFuture$AsyncRun.run(Unknown Source) at java.base/java.lang.Thread.run(Unknown Source) 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:2887) Caused by: java.lang.NumberFormatException: For input string: "" at java.base/java.lang.NumberFormatException.forInputString(Unknown Source) at java.base/java.lang.Long.parseLong(Unknown Source) at java.base/java.lang.Long.parseLong(Unknown Source) at ar.com.branded.ms_look.look.adapter.in.kafka.model.LookAlgorithm.applyRelevanceFactors(LookAlgorithm.kt:89) at ar.com.branded.ms_look.look.adapter.in.kafka.model.LookAlgorithm.calculateScore(LookAlgorithm.kt:24) at ar.com.branded.ms_look.look.adapter.in.kafka.model.LookAlgorithm.generateCompositeScore(LookAlgorithm.kt:42) at ar.com.branded.ms_look.look.application.usecase.RegisterLooksAlgorithmUseCase.handleFollowUser(RegisterLooksAlgorithmUseCase.kt:143) at ar.com.branded.ms_look.look.application.usecase.RegisterLooksAlgorithmUseCase.execute(RegisterLooksAlgorithmUseCase.kt:36) at ar.com.branded.ms_look.look.adapter.in.kafka.LookAlgorithmKafkaAdapter.listen(LookAlgorithmKafkaAdapter.kt:23) at jdk.internal.reflect.GeneratedMethodAccessor103.invoke(Unknown Source) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) at java.base/java.lang.reflect.Method.invoke(Unknown Source) 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:2887) ... 10 more , kafka_dlt-original-consumer-group: looks, kafka_dlt-original-offset: C�, kafka_dlt-original-partition: , kafka_dlt-original-timestamp: ��h8, kafka_dlt-original-timestamp-type: CreateTime, kafka_dlt-original-topic: look-algorithm-topic

{"userId":"fa6c9870-b22c-4299-a3b3-3c91dec1d26b","lookId":"","type":"FOLLOW_USER","targetUserId":"9057adc8-ced6-4547-9b4a-dc92d0b7c7d8"}

{"userId":"fa6c9870-b22c-4299-a3b3-3c91dec1d26b","lookId":"","type":"FOLLOW_USER","targetUserId":"9057adc8-ced6-4547-9b4a-dc92d0b7c7d8"}