API tools faq
paste
Advertisement
fedorm

Untitled

fedorm
Mar 1st, 2019
213
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 46.02 KB | None | 0 0
raw download clone embed print report
  1.  
  2. 2019-03-01 16:41:33.616 ERROR 1 --- [ntainer#4-0-C-1] essageListenerContainer$ListenerConsumer : Error handler threw an exception
  3.  
  4. org.springframework.kafka.KafkaException: Seek to current after exception; nested exception is org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.retry(ru.crystals.processing.coupons.kafka.domain.GenerateCouponsTask,java.lang.Long)' threw exception; nested exception is ru.crystals.processing.coupons.kafka.exception.KafkaListenerException: Not found batch by id = 1
  5. at org.springframework.kafka.listener.SeekToCurrentErrorHandler.handle(SeekToCurrentErrorHandler.java:47) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  6. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1108) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  7. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1051) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  8. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:998) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  9. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:866) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  10. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:724) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  11. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_181]
  12. at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_181]
  13. at java.lang.Thread.run(Thread.java:748) [na:1.8.0_181]
  14. Caused by: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.retry(ru.crystals.processing.coupons.kafka.domain.GenerateCouponsTask,java.lang.Long)' threw exception; nested exception is ru.crystals.processing.coupons.kafka.exception.KafkaListenerException: Not found batch by id = 1
  15. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:267) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  16. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:80) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  17. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  18. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1071) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  19. ... 7 common frames omitted
  20. Caused by: ru.crystals.processing.coupons.kafka.exception.KafkaListenerException: Not found batch by id = 1
  21. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.lambda$generateCoupons$0(GenerateCouponSeriesConsumerService.java:95) ~[classes!/:na]
  22. at java.util.Optional.orElseThrow(Optional.java:290) ~[na:1.8.0_181]
  23. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.generateCoupons(GenerateCouponSeriesConsumerService.java:95) ~[classes!/:na]
  24. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.retry(GenerateCouponSeriesConsumerService.java:82) ~[classes!/:na]
  25. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService$$FastClassBySpringCGLIB$$17ad52b8.invoke(<generated>) ~[classes!/:na]
  26. at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204) ~[spring-core-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  27. at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:746) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  28. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  29. at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:294) ~[spring-tx-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  30. at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:98) ~[spring-tx-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  31. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  32. at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:688) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  33. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService$$EnhancerBySpringCGLIB$$4a94d1b8.retry(<generated>) ~[classes!/:na]
  34. at sun.reflect.GeneratedMethodAccessor110.invoke(Unknown Source) ~[na:na]
  35. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_181]
  36. at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_181]
  37. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:181) ~[spring-messaging-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  38. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:114) ~[spring-messaging-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  39. at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  40. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:248) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  41. ... 10 common frames omitted
  42.  
  43. 2019-03-01 16:41:33.626 ERROR 1 --- [ntainer#4-0-C-1] essageListenerContainer$ListenerConsumer : Error handler threw an exception
  44.  
  45. org.springframework.kafka.KafkaException: Seek to current after exception; nested exception is org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.retry(ru.crystals.processing.coupons.kafka.domain.GenerateCouponsTask,java.lang.Long)' threw exception; nested exception is ru.crystals.processing.coupons.kafka.exception.KafkaListenerException: Not found batch by id = 1
  46. at org.springframework.kafka.listener.SeekToCurrentErrorHandler.handle(SeekToCurrentErrorHandler.java:47) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  47. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1108) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  48. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1051) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  49. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:998) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  50. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:866) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  51. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:724) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  52. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_181]
  53. at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_181]
  54. at java.lang.Thread.run(Thread.java:748) [na:1.8.0_181]
  55. Caused by: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.retry(ru.crystals.processing.coupons.kafka.domain.GenerateCouponsTask,java.lang.Long)' threw exception; nested exception is ru.crystals.processing.coupons.kafka.exception.KafkaListenerException: Not found batch by id = 1
  56. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:267) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  57. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:80) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  58. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  59. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1071) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  60. ... 7 common frames omitted
  61. Caused by: ru.crystals.processing.coupons.kafka.exception.KafkaListenerException: Not found batch by id = 1
  62. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.lambda$generateCoupons$0(GenerateCouponSeriesConsumerService.java:95) ~[classes!/:na]
  63. at java.util.Optional.orElseThrow(Optional.java:290) ~[na:1.8.0_181]
  64. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.generateCoupons(GenerateCouponSeriesConsumerService.java:95) ~[classes!/:na]
  65. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.retry(GenerateCouponSeriesConsumerService.java:82) ~[classes!/:na]
  66. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService$$FastClassBySpringCGLIB$$17ad52b8.invoke(<generated>) ~[classes!/:na]
  67. at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204) ~[spring-core-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  68. at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:746) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  69. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  70. at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:294) ~[spring-tx-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  71. at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:98) ~[spring-tx-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  72. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  73. at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:688) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  74. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService$$EnhancerBySpringCGLIB$$4a94d1b8.retry(<generated>) ~[classes!/:na]
  75. at sun.reflect.GeneratedMethodAccessor110.invoke(Unknown Source) ~[na:na]
  76. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_181]
  77. at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_181]
  78. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:181) ~[spring-messaging-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  79. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:114) ~[spring-messaging-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  80. at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  81. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:248) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  82. ... 10 common frames omitted
  83.  
  84. 2019-03-01 16:41:33.637 ERROR 1 --- [ntainer#4-0-C-1] essageListenerContainer$ListenerConsumer : Error handler threw an exception
  85.  
  86. org.springframework.kafka.KafkaException: Seek to current after exception; nested exception is org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.retry(ru.crystals.processing.coupons.kafka.domain.GenerateCouponsTask,java.lang.Long)' threw exception; nested exception is ru.crystals.processing.coupons.kafka.exception.KafkaListenerException: Not found batch by id = 1
  87. at org.springframework.kafka.listener.SeekToCurrentErrorHandler.handle(SeekToCurrentErrorHandler.java:47) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  88. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1108) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  89. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1051) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  90. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:998) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  91. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:866) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  92. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:724) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  93. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_181]
  94. at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_181]
  95. at java.lang.Thread.run(Thread.java:748) [na:1.8.0_181]
  96. Caused by: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.retry(ru.crystals.processing.coupons.kafka.domain.GenerateCouponsTask,java.lang.Long)' threw exception; nested exception is ru.crystals.processing.coupons.kafka.exception.KafkaListenerException: Not found batch by id = 1
  97. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:267) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  98. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:80) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  99. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  100. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1071) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  101. ... 7 common frames omitted
  102. Caused by: ru.crystals.processing.coupons.kafka.exception.KafkaListenerException: Not found batch by id = 1
  103. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.lambda$generateCoupons$0(GenerateCouponSeriesConsumerService.java:95) ~[classes!/:na]
  104. at java.util.Optional.orElseThrow(Optional.java:290) ~[na:1.8.0_181]
  105. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.generateCoupons(GenerateCouponSeriesConsumerService.java:95) ~[classes!/:na]
  106. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.retry(GenerateCouponSeriesConsumerService.java:82) ~[classes!/:na]
  107. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService$$FastClassBySpringCGLIB$$17ad52b8.invoke(<generated>) ~[classes!/:na]
  108. at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204) ~[spring-core-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  109. at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:746) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  110. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  111. at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:294) ~[spring-tx-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  112. at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:98) ~[spring-tx-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  113. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  114. at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:688) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  115. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService$$EnhancerBySpringCGLIB$$4a94d1b8.retry(<generated>) ~[classes!/:na]
  116. at sun.reflect.GeneratedMethodAccessor110.invoke(Unknown Source) ~[na:na]
  117. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_181]
  118. at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_181]
  119. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:181) ~[spring-messaging-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  120. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:114) ~[spring-messaging-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  121. at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  122. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:248) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  123. ... 10 common frames omitted
  124.  
  125. 2019-03-01 16:41:33.647 ERROR 1 --- [ntainer#4-0-C-1] essageListenerContainer$ListenerConsumer : Error handler threw an exception
  126.  
  127. org.springframework.kafka.KafkaException: Seek to current after exception; nested exception is org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.retry(ru.crystals.processing.coupons.kafka.domain.GenerateCouponsTask,java.lang.Long)' threw exception; nested exception is ru.crystals.processing.coupons.kafka.exception.KafkaListenerException: Not found batch by id = 1
  128. at org.springframework.kafka.listener.SeekToCurrentErrorHandler.handle(SeekToCurrentErrorHandler.java:47) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  129. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1108) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  130. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1051) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  131. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:998) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  132. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:866) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  133. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:724) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  134. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_181]
  135. at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_181]
  136. at java.lang.Thread.run(Thread.java:748) [na:1.8.0_181]
  137. Caused by: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.retry(ru.crystals.processing.coupons.kafka.domain.GenerateCouponsTask,java.lang.Long)' threw exception; nested exception is ru.crystals.processing.coupons.kafka.exception.KafkaListenerException: Not found batch by id = 1
  138. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:267) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  139. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:80) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  140. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  141. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1071) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  142. ... 7 common frames omitted
  143. Caused by: ru.crystals.processing.coupons.kafka.exception.KafkaListenerException: Not found batch by id = 1
  144. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.lambda$generateCoupons$0(GenerateCouponSeriesConsumerService.java:95) ~[classes!/:na]
  145. at java.util.Optional.orElseThrow(Optional.java:290) ~[na:1.8.0_181]
  146. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.generateCoupons(GenerateCouponSeriesConsumerService.java:95) ~[classes!/:na]
  147. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.retry(GenerateCouponSeriesConsumerService.java:82) ~[classes!/:na]
  148. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService$$FastClassBySpringCGLIB$$17ad52b8.invoke(<generated>) ~[classes!/:na]
  149. at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204) ~[spring-core-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  150. at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:746) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  151. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  152. at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:294) ~[spring-tx-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  153. at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:98) ~[spring-tx-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  154. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  155. at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:688) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  156. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService$$EnhancerBySpringCGLIB$$4a94d1b8.retry(<generated>) ~[classes!/:na]
  157. at sun.reflect.GeneratedMethodAccessor110.invoke(Unknown Source) ~[na:na]
  158. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_181]
  159. at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_181]
  160. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:181) ~[spring-messaging-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  161. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:114) ~[spring-messaging-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  162. at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  163. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:248) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  164. ... 10 common frames omitted
  165.  
  166. 2019-03-01 16:41:33.671 ERROR 1 --- [ntainer#4-0-C-1] essageListenerContainer$ListenerConsumer : Error handler threw an exception
  167.  
  168. org.springframework.kafka.KafkaException: Seek to current after exception; nested exception is org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.retry(ru.crystals.processing.coupons.kafka.domain.GenerateCouponsTask,java.lang.Long)' threw exception; nested exception is ru.crystals.processing.coupons.kafka.exception.KafkaListenerException: Not found batch by id = 1
  169. at org.springframework.kafka.listener.SeekToCurrentErrorHandler.handle(SeekToCurrentErrorHandler.java:47) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  170. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1108) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  171. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1051) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  172. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:998) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  173. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:866) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  174. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:724) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  175. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_181]
  176. at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_181]
  177. at java.lang.Thread.run(Thread.java:748) [na:1.8.0_181]
  178. Caused by: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.retry(ru.crystals.processing.coupons.kafka.domain.GenerateCouponsTask,java.lang.Long)' threw exception; nested exception is ru.crystals.processing.coupons.kafka.exception.KafkaListenerException: Not found batch by id = 1
  179. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:267) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  180. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:80) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  181. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  182. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1071) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  183. ... 7 common frames omitted
  184. Caused by: ru.crystals.processing.coupons.kafka.exception.KafkaListenerException: Not found batch by id = 1
  185. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.lambda$generateCoupons$0(GenerateCouponSeriesConsumerService.java:95) ~[classes!/:na]
  186. at java.util.Optional.orElseThrow(Optional.java:290) ~[na:1.8.0_181]
  187. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.generateCoupons(GenerateCouponSeriesConsumerService.java:95) ~[classes!/:na]
  188. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.retry(GenerateCouponSeriesConsumerService.java:82) ~[classes!/:na]
  189. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService$$FastClassBySpringCGLIB$$17ad52b8.invoke(<generated>) ~[classes!/:na]
  190. at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204) ~[spring-core-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  191. at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:746) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  192. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  193. at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:294) ~[spring-tx-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  194. at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:98) ~[spring-tx-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  195. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  196. at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:688) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  197. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService$$EnhancerBySpringCGLIB$$4a94d1b8.retry(<generated>) ~[classes!/:na]
  198. at sun.reflect.GeneratedMethodAccessor110.invoke(Unknown Source) ~[na:na]
  199. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_181]
  200. at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_181]
  201. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:181) ~[spring-messaging-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  202. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:114) ~[spring-messaging-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  203. at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  204. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:248) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  205. ... 10 common frames omitted
  206.  
  207. 2019-03-01 16:41:33.681 ERROR 1 --- [ntainer#4-0-C-1] essageListenerContainer$ListenerConsumer : Error handler threw an exception
  208.  
  209. org.springframework.kafka.KafkaException: Seek to current after exception; nested exception is org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.retry(ru.crystals.processing.coupons.kafka.domain.GenerateCouponsTask,java.lang.Long)' threw exception; nested exception is ru.crystals.processing.coupons.kafka.exception.KafkaListenerException: Not found batch by id = 1
  210. at org.springframework.kafka.listener.SeekToCurrentErrorHandler.handle(SeekToCurrentErrorHandler.java:47) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  211. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1108) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  212. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1051) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  213. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:998) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  214. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:866) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  215. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:724) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  216. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_181]
  217. at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_181]
  218. at java.lang.Thread.run(Thread.java:748) [na:1.8.0_181]
  219. Caused by: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.retry(ru.crystals.processing.coupons.kafka.domain.GenerateCouponsTask,java.lang.Long)' threw exception; nested exception is ru.crystals.processing.coupons.kafka.exception.KafkaListenerException: Not found batch by id = 1
  220. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:267) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  221. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:80) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  222. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  223. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1071) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  224. ... 7 common frames omitted
  225. Caused by: ru.crystals.processing.coupons.kafka.exception.KafkaListenerException: Not found batch by id = 1
  226. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.lambda$generateCoupons$0(GenerateCouponSeriesConsumerService.java:95) ~[classes!/:na]
  227. at java.util.Optional.orElseThrow(Optional.java:290) ~[na:1.8.0_181]
  228. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.generateCoupons(GenerateCouponSeriesConsumerService.java:95) ~[classes!/:na]
  229. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.retry(GenerateCouponSeriesConsumerService.java:82) ~[classes!/:na]
  230. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService$$FastClassBySpringCGLIB$$17ad52b8.invoke(<generated>) ~[classes!/:na]
  231. at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204) ~[spring-core-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  232. at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:746) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  233. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  234. at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:294) ~[spring-tx-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  235. at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:98) ~[spring-tx-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  236. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  237. at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:688) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  238. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService$$EnhancerBySpringCGLIB$$4a94d1b8.retry(<generated>) ~[classes!/:na]
  239. at sun.reflect.GeneratedMethodAccessor110.invoke(Unknown Source) ~[na:na]
  240. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_181]
  241. at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_181]
  242. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:181) ~[spring-messaging-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  243. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:114) ~[spring-messaging-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  244. at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  245. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:248) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  246. ... 10 common frames omitted
  247.  
  248. 2019-03-01 16:41:33.696 ERROR 1 --- [ntainer#4-0-C-1] essageListenerContainer$ListenerConsumer : Error handler threw an exception
  249.  
  250. org.springframework.kafka.KafkaException: Seek to current after exception; nested exception is org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.retry(ru.crystals.processing.coupons.kafka.domain.GenerateCouponsTask,java.lang.Long)' threw exception; nested exception is ru.crystals.processing.coupons.kafka.exception.KafkaListenerException: Not found batch by id = 1
  251. at org.springframework.kafka.listener.SeekToCurrentErrorHandler.handle(SeekToCurrentErrorHandler.java:47) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  252. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1108) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  253. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1051) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  254. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:998) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  255. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:866) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  256. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:724) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  257. at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_181]
  258. at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_181]
  259. at java.lang.Thread.run(Thread.java:748) [na:1.8.0_181]
  260. Caused by: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.retry(ru.crystals.processing.coupons.kafka.domain.GenerateCouponsTask,java.lang.Long)' threw exception; nested exception is ru.crystals.processing.coupons.kafka.exception.KafkaListenerException: Not found batch by id = 1
  261. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:267) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  262. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:80) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  263. at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  264. at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1071) [spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  265. ... 7 common frames omitted
  266. Caused by: ru.crystals.processing.coupons.kafka.exception.KafkaListenerException: Not found batch by id = 1
  267. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.lambda$generateCoupons$0(GenerateCouponSeriesConsumerService.java:95) ~[classes!/:na]
  268. at java.util.Optional.orElseThrow(Optional.java:290) ~[na:1.8.0_181]
  269. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.generateCoupons(GenerateCouponSeriesConsumerService.java:95) ~[classes!/:na]
  270. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService.retry(GenerateCouponSeriesConsumerService.java:82) ~[classes!/:na]
  271. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService$$FastClassBySpringCGLIB$$17ad52b8.invoke(<generated>) ~[classes!/:na]
  272. at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:204) ~[spring-core-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  273. at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:746) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  274. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  275. at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:294) ~[spring-tx-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  276. at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:98) ~[spring-tx-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  277. at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:185) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  278. at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:688) ~[spring-aop-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  279. at ru.crystals.processing.coupons.consumer.series.GenerateCouponSeriesConsumerService$$EnhancerBySpringCGLIB$$4a94d1b8.retry(<generated>) ~[classes!/:na]
  280. at sun.reflect.GeneratedMethodAccessor110.invoke(Unknown Source) ~[na:na]
  281. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_181]
  282. at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_181]
  283. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:181) ~[spring-messaging-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  284. at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:114) ~[spring-messaging-5.0.6.RELEASE.jar!/:5.0.6.RELEASE]
  285. at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  286. at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:248) ~[spring-kafka-2.1.6.RELEASE.jar!/:2.1.6.RELEASE]
  287. ... 10 common frames omitted
  288.  
  289. 2019-03-01 16:41:33.697 INFO 1 --- [ntainer#4-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-3, groupId=coupon-processing-consumer-group] Revoking previously assigned partitions [generate_coupons_retry-0]
  290. 2019-03-01 16:41:33.697 INFO 1 --- [ntainer#4-0-C-1] o.s.k.l.KafkaMessageListenerContainer : partitions revoked: [generate_coupons_retry-0]
  291. 2019-03-01 16:41:33.697 INFO 1 --- [ntainer#4-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-3, groupId=coupon-processing-consumer-group] (Re-)joining group
  292. 2019-03-01 16:41:33.698 INFO 1 --- [ntainer#5-1-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-6, groupId=coupon-processing-consumer-group] Revoking previously assigned partitions []
  293. 2019-03-01 16:41:33.698 INFO 1 --- [ntainer#5-1-C-1] o.s.k.l.KafkaMessageListenerContainer : partitions revoked: []
  294. 2019-03-01 16:41:33.698 INFO 1 --- [ntainer#5-1-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-6, groupId=coupon-processing-consumer-group] (Re-)joining group
  295. 2019-03-01 16:41:33.700 INFO 1 --- [ntainer#2-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-1, groupId=coupon-processing-consumer-group] Revoking previously assigned partitions [file_import_coupons_retry-0]
  296. 2019-03-01 16:41:33.700 INFO 1 --- [ntainer#2-0-C-1] o.s.k.l.KafkaMessageListenerContainer : partitions revoked: [file_import_coupons_retry-0]
  297. 2019-03-01 16:41:33.700 INFO 1 --- [ntainer#2-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-1, groupId=coupon-processing-consumer-group] (Re-)joining group
  298. 2019-03-01 16:41:33.700 INFO 1 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-7, groupId=coupon-processing-consumer-group] Revoking previously assigned partitions [coupon_action_retry-0]
  299. 2019-03-01 16:41:33.700 INFO 1 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : partitions revoked: [coupon_action_retry-0]
  300. 2019-03-01 16:41:33.701 INFO 1 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-7, groupId=coupon-processing-consumer-group] (Re-)joining group
  301. 2019-03-01 16:41:33.702 INFO 1 --- [ntainer#3-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-2, groupId=coupon-processing-consumer-group] Revoking previously assigned partitions [file_import_coupons-0]
  302. 2019-03-01 16:41:33.702 INFO 1 --- [ntainer#3-0-C-1] o.s.k.l.KafkaMessageListenerContainer : partitions revoked: [file_import_coupons-0]
  303. 2019-03-01 16:41:33.702 INFO 1 --- [ntainer#3-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-2, groupId=coupon-processing-consumer-group] (Re-)joining group
  304. 2019-03-01 16:41:33.703 INFO 1 --- [ntainer#1-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-9, groupId=coupon-processing-consumer-group] Revoking previously assigned partitions []
  305. 2019-03-01 16:41:33.703 INFO 1 --- [ntainer#1-0-C-1] o.s.k.l.KafkaMessageListenerContainer : partitions revoked: []
  306. 2019-03-01 16:41:33.703 INFO 1 --- [ntainer#4-1-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-4, groupId=coupon-processing-consumer-group] Revoking previously assigned partitions []
  307. 2019-03-01 16:41:33.703 INFO 1 --- [ntainer#1-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-9, groupId=coupon-processing-consumer-group] (Re-)joining group
  308. 2019-03-01 16:41:33.703 INFO 1 --- [ntainer#4-1-C-1] o.s.k.l.KafkaMessageListenerContainer : partitions revoked: []
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
Public Pastes
Advertisement
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!