Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- 2019-01-24 12:25:16.386 DEBUG 1 --- [ntainer#0-1-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
- 2019-01-24 12:25:16.386 DEBUG 1 --- [ntainer#0-1-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
- 2019-01-24 12:25:16.498 DEBUG 1 --- [ntainer#0-8-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
- 2019-01-24 12:25:16.498 DEBUG 1 --- [ntainer#0-8-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
- 2019-01-24 12:25:16.553 DEBUG 1 --- [ntainer#0-4-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
- 2019-01-24 12:25:16.554 DEBUG 1 --- [ntainer#0-4-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
- 2019-01-24 12:25:16.782 DEBUG 1 --- [ntainer#0-2-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
- 2019-01-24 12:25:16.783 DEBUG 1 --- [ntainer#0-2-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
- 2019-01-24 12:25:16.806 DEBUG 1 --- [ntainer#0-7-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
- 2019-01-24 12:25:16.806 DEBUG 1 --- [ntainer#0-7-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
- 2019-01-24 12:25:16.835 DEBUG 1 --- [ntainer#0-9-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
- 2019-01-24 12:25:16.835 DEBUG 1 --- [ntainer#0-9-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
- 2019-01-24 12:25:16.876 DEBUG 1 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
- 2019-01-24 12:25:16.877 DEBUG 1 --- [ntainer#0-0-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
- 2019-01-24 12:25:16.880 DEBUG 1 --- [ntainer#0-9-C-1] essageListenerContainer$ListenerConsumer : Received: 1 records
- 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}]]
- 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"})
- org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method could not be invoked with the incoming message
- Endpoint handler details:
- Method [public void ru.crystals.processing.coupons.batchgenerate.service.BatchGenerateCouponSeriesConsumerService.receive(ru.crystals.processing.coupons.kafka.domain.GenerateCouponsTask,java.lang.Long)]
- 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}]
- at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:257) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
- at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:80) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
- at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
- at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1071) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
- at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1051) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
- at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:998) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
- at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:866) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
- at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:724) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
- at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_181]
- at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_181]
- at java.lang.Thread.run(Thread.java:748) [na:1.8.0_181]
- 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}]
- ... 11 common frames omitted
- 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}]
- at org.springframework.messaging.handler.annotation.support.PayloadArgumentResolver.resolveArgument(PayloadArgumentResolver.java:144) ~[spring-messaging-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
- at org.springframework.messaging.handler.invocation.HandlerMethodArgumentResolverComposite.resolveArgument(HandlerMethodArgumentResolverComposite.java:116) ~[spring-messaging-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
- at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.getMethodArgumentValues(InvocableHandlerMethod.java:137) ~[spring-messaging-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
- at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:109) ~[spring-messaging-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
- at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
- at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:248) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
- ... 10 common frames omitted
- 2019-01-24 12:25:16.895 DEBUG 1 --- [ntainer#0-9-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
- 2019-01-24 12:25:16.904 DEBUG 1 --- [ntainer#0-6-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
- 2019-01-24 12:25:16.904 DEBUG 1 --- [ntainer#0-6-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
- 2019-01-24 12:25:16.940 DEBUG 1 --- [ntainer#0-3-C-1] essageListenerContainer$ListenerConsumer : Received: 0 records
- 2019-01-24 12:25:16.940 DEBUG 1 --- [ntainer#0-3-C-1] essageListenerContainer$ListenerConsumer : Commit list: {}
- 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