Advertisement
Guest User

fedorm

a guest
Jan 24th, 2019
105
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
XML 9.56 KB | None | 0 0
  1. 2019-01-24 12:25:16.386 DEBUG 1 --- [ntainer#0-1-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
  2. 2019-01-24 12:25:16.386 DEBUG 1 --- [ntainer#0-1-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
  3. 2019-01-24 12:25:16.498 DEBUG 1 --- [ntainer#0-8-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
  4. 2019-01-24 12:25:16.498 DEBUG 1 --- [ntainer#0-8-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
  5. 2019-01-24 12:25:16.553 DEBUG 1 --- [ntainer#0-4-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
  6. 2019-01-24 12:25:16.554 DEBUG 1 --- [ntainer#0-4-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
  7. 2019-01-24 12:25:16.782 DEBUG 1 --- [ntainer#0-2-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
  8. 2019-01-24 12:25:16.783 DEBUG 1 --- [ntainer#0-2-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
  9. 2019-01-24 12:25:16.806 DEBUG 1 --- [ntainer#0-7-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
  10. 2019-01-24 12:25:16.806 DEBUG 1 --- [ntainer#0-7-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
  11. 2019-01-24 12:25:16.835 DEBUG 1 --- [ntainer#0-9-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
  12. 2019-01-24 12:25:16.835 DEBUG 1 --- [ntainer#0-9-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
  13. 2019-01-24 12:25:16.876 DEBUG 1 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
  14. 2019-01-24 12:25:16.877 DEBUG 1 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
  15. 2019-01-24 12:25:16.880 DEBUG 1 --- [ntainer#0-9-C-1] essageListenerContainer$ListenerConsumer : Received: 1 records
  16. 2019-01-24 12:25:16.886 DEBUG 1 --- [ntainer#0-9-C-1] .a.RecordMessagingMessageListenerAdapter : Processing [GenericMessage [payload={"categoryId":1,"batchId":2,"startIndex":0,"endIndex":36,"startDate":"2019-01-24T09:25:13.206Z","endDate":"2019-01-25T09:25:13.206Z"}, headers={kafka_offset=0, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@6f3b0271, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=null, kafka_receivedPartitionId=1, kafka_receivedTopic=generate_coupons, kafka_receivedTimestamp=1548321915519}]]
  17. 2019-01-24 12:25:16.894 ERROR 1 --- [ntainer#0-9-C-1] o.s.kafka.listener.LoggingErrorHandler   : Error while processing: ConsumerRecord(topic = generate_coupons, partition = 1, offset = 0, CreateTime = 1548321915519, serialized key size = -1, serialized value size = 133, headers = RecordHeaders(headers = [], isReadOnly = false), key = null, value = {"categoryId":1,"batchId":2,"startIndex":0,"endIndex":36,"startDate":"2019-01-24T09:25:13.206Z","endDate":"2019-01-25T09:25:13.206Z"})
  18.  
  19. org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method could not be invoked with the incoming message
  20. Endpoint handler details:
  21. Method [public void ru.crystals.processing.coupons.batchgenerate.service.BatchGenerateCouponSeriesConsumerService.receive(ru.crystals.processing.coupons.kafka.domain.GenerateCouponsTask,java.lang.Long)]
  22. Bean [ru.crystals.processing.coupons.batchgenerate.service.BatchGenerateCouponSeriesConsumerService@68b6f0d6]; nested exception is org.springframework.messaging.converter.MessageConversionException: Cannot handle message; nested exception is org.springframework.messaging.converter.MessageConversionException: Cannot convert from [java.lang.String] to [ru.crystals.processing.coupons.kafka.domain.GenerateCouponsTask] for GenericMessage [payload={"categoryId":1,"batchId":2,"startIndex":0,"endIndex":36,"startDate":"2019-01-24T09:25:13.206Z","endDate":"2019-01-25T09:25:13.206Z"}, headers={kafka_offset=0, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@6f3b0271, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=null, kafka_receivedPartitionId=1, kafka_receivedTopic=generate_coupons, kafka_receivedTimestamp=1548321915519}], failedMessage=GenericMessage [payload={"categoryId":1,"batchId":2,"startIndex":0,"endIndex":36,"startDate":"2019-01-24T09:25:13.206Z","endDate":"2019-01-25T09:25:13.206Z"}, headers={kafka_offset=0, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@6f3b0271, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=null, kafka_receivedPartitionId=1, kafka_receivedTopic=generate_coupons, kafka_receivedTimestamp=1548321915519}]
  23.     at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:257) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  24.     at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:80) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  25.     at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  26.     at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1071) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  27.     at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1051) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  28.     at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:998) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  29.     at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:866) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  30.     at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:724) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  31.     at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_181]
  32.     at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_181]
  33.     at java.lang.Thread.run(Thread.java:748) [na:1.8.0_181]
  34. Caused by: org.springframework.messaging.converter.MessageConversionException: Cannot handle message; nested exception is org.springframework.messaging.converter.MessageConversionException: Cannot convert from [java.lang.String] to [ru.crystals.processing.coupons.kafka.domain.GenerateCouponsTask] for GenericMessage [payload={"categoryId":1,"batchId":2,"startIndex":0,"endIndex":36,"startDate":"2019-01-24T09:25:13.206Z","endDate":"2019-01-25T09:25:13.206Z"}, headers={kafka_offset=0, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@6f3b0271, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=null, kafka_receivedPartitionId=1, kafka_receivedTopic=generate_coupons, kafka_receivedTimestamp=1548321915519}], failedMessage=GenericMessage [payload={"categoryId":1,"batchId":2,"startIndex":0,"endIndex":36,"startDate":"2019-01-24T09:25:13.206Z","endDate":"2019-01-25T09:25:13.206Z"}, headers={kafka_offset=0, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@6f3b0271, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=null, kafka_receivedPartitionId=1, kafka_receivedTopic=generate_coupons, kafka_receivedTimestamp=1548321915519}]
  35.     ... 11 common frames omitted
  36. Caused by: org.springframework.messaging.converter.MessageConversionException: Cannot convert from [java.lang.String] to [ru.crystals.processing.coupons.kafka.domain.GenerateCouponsTask] for GenericMessage [payload={"categoryId":1,"batchId":2,"startIndex":0,"endIndex":36,"startDate":"2019-01-24T09:25:13.206Z","endDate":"2019-01-25T09:25:13.206Z"}, headers={kafka_offset=0, kafka_consumer=org.apache.kafka.clients.consumer.KafkaConsumer@6f3b0271, kafka_timestampType=CREATE_TIME, kafka_receivedMessageKey=null, kafka_receivedPartitionId=1, kafka_receivedTopic=generate_coupons, kafka_receivedTimestamp=1548321915519}]
  37.     at org.springframework.messaging.handler.annotation.support.PayloadArgumentResolver.resolveArgument(PayloadArgumentResolver.java:144) ~[spring-messaging-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  38.     at org.springframework.messaging.handler.invocation.HandlerMethodArgumentResolverComposite.resolveArgument(HandlerMethodArgumentResolverComposite.java:116) ~[spring-messaging-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  39.     at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.getMethodArgumentValues(InvocableHandlerMethod.java:137) ~[spring-messaging-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  40.     at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:109) ~[spring-messaging-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  41.     at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  42.     at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:248) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  43.     ... 10 common frames omitted
  44.  
  45. 2019-01-24 12:25:16.895 DEBUG 1 --- [ntainer#0-9-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
  46. 2019-01-24 12:25:16.904 DEBUG 1 --- [ntainer#0-6-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
  47. 2019-01-24 12:25:16.904 DEBUG 1 --- [ntainer#0-6-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
  48. 2019-01-24 12:25:16.940 DEBUG 1 --- [ntainer#0-3-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
  49. 2019-01-24 12:25:16.940 DEBUG 1 --- [ntainer#0-3-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
  50. 2019-01-24 12:25:16.969 DEBUG 1 --- [ntainer#0-5-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement