kafa-demo SeekToCurrentErrorHandler 不止3次

Author: zwx2238Created Mar 14, 2022Updated Jan 2, 2024

2022-03-14 18:23:19.967 INFO 12440 --- [ main] c.i.s.l.k.producer.Demo04ProducerTest : [testSyncSend][发送编号：[1647253399] 发送结果：[SendResult [producerRecord=ProducerRecord(topic=DEMO_04, partition=null, headers=RecordHeaders(headers = [RecordHeader(key = TypeId, value = [99, 110, 46, 105, 111, 99, 111, 100, 101, 114, 46, 115, 112, 114, 105, 110, 103, 98, 111, 111, 116, 46, 108, 97, 98, 48, 51, 46, 107, 97, 102, 107, 97, 100, 101, 109, 111, 46, 109, 101, 115, 115, 97, 103, 101, 46, 68, 101, 109, 111, 48, 52, 77, 101, 115, 115, 97, 103, 101])], isReadOnly = true), key=null, value=Demo04Message{id=1647253399}, timestamp=null), recordMetadata=DEMO_04-0@5]]] 2022-03-14 18:23:19.978 INFO 12440 --- [ntainer#2-0-C-1] c.i.s.l.k.consumer.Demo04Consumer : [onMessage][线程编号:16 消息内容：Demo04Message{id=1647252073}] 2022-03-14 18:23:29.999 ERROR 12440 --- [ntainer#2-0-C-1] essageListenerContainer$ListenerConsumer : Error handler threw an exception

org.springframework.kafka.KafkaException: Seek to current after exception; nested exception is org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void cn.iocoder.springboot.lab03.kafkademo.consumer.Demo04Consumer.onMessage(cn.iocoder.springboot.lab03.kafkademo.message.Demo04Message)' threw exception; nested exception is java.lang.RuntimeException: 我就是故意抛出一个异常; nested exception is java.lang.RuntimeException: 我就是故意抛出一个异常 at org.springframework.kafka.listener.SeekToCurrentErrorHandler.handle(SeekToCurrentErrorHandler.java:200) ~[spring-kafka-2.3.3.RELEASE.jar:2.3.3.RELEASE] at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeErrorHandler(KafkaMessageListenerContainer.java:1674) [spring-kafka-2.3.3.RELEASE.jar:2.3.3.RELEASE] at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1591) [spring-kafka-2.3.3.RELEASE.jar:2.3.3.RELEASE] at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1532) [spring-kafka-2.3.3.RELEASE.jar:2.3.3.RELEASE] at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1446) [spring-kafka-2.3.3.RELEASE.jar:2.3.3.RELEASE] at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1196) [spring-kafka-2.3.3.RELEASE.jar:2.3.3.RELEASE] at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:955) [spring-kafka-2.3.3.RELEASE.jar:2.3.3.RELEASE] at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:890) [spring-kafka-2.3.3.RELEASE.jar:2.3.3.RELEASE] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_312] at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_312] at java.lang.Thread.run(Thread.java:748) [na:1.8.0_312] Caused by: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void cn.iocoder.springboot.lab03.kafkademo.consumer.Demo04Consumer.onMessage(cn.iocoder.springboot.lab03.kafkademo.message.Demo04Message)' threw exception; nested exception is java.lang.RuntimeException: 我就是故意抛出一个异常; nested exception is java.lang.RuntimeException: 我就是故意抛出一个异常 at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:1686) [spring-kafka-2.3.3.RELEASE.jar:2.3.3.RELEASE] ... 10 common frames omitted Caused by: java.lang.RuntimeException: 我就是故意抛出一个异常 at cn.iocoder.springboot.lab03.kafkademo.consumer.Demo04Consumer.onMessage(Demo04Consumer.java:23) ~[classes/:na] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.8.0_312] at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[na:1.8.0_312] at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.8.0_312] at java.lang.reflect.Method.invoke(Method.java:498) ~[na:1.8.0_312] at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:171) ~[spring-messaging-5.2.1.RELEASE.jar:5.2.1.RELEASE] at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:120) ~[spring-messaging-5.2.1.RELEASE.jar:5.2.1.RELEASE] at org.springframework.kafka.listener.adapter.HandlerAdapter.invoke(HandlerAdapter.java:48) ~[spring-kafka-2.3.3.RELEASE.jar:2.3.3.RELEASE] at org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.invokeHandler(MessagingMessageListenerAdapter.java:304) ~[spring-kafka-2.3.3.RELEASE.jar:2.3.3.RELEASE] at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:86) ~[spring-kafka-2.3.3.RELEASE.jar:2.3.3.RELEASE] at org.springframework.kafka.listener.adapter.RecordMessagingMessageListenerAdapter.onMessage(RecordMessagingMessageListenerAdapter.java:51) ~[spring-kafka-2.3.3.RELEASE.jar:2.3.3.RELEASE] at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeOnMessage(KafkaMessageListenerContainer.java:1640) [spring-kafka-2.3.3.RELEASE.jar:2.3.3.RELEASE] at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeOnMessage(KafkaMessageListenerContainer.java:1623) [spring-kafka-2.3.3.RELEASE.jar:2.3.3.RELEASE] at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1578) [spring-kafka-2.3.3.RELEASE.jar:2.3.3.RELEASE] ... 8 common frames omitted

2022-03-14 18:23:30.002 INFO 12440 --- [ntainer#2-0-C-1] c.i.s.l.k.consumer.Demo04Consumer : [onMessage][线程编号:16 消息内容：Demo04Message{id=1647252073}] 2022-03-14 18:23:40.015 ERROR 12440 --- [ntainer#2-0-C-1] essageListenerContainer$ListenerConsumer : Error handler threw an exception

2022-03-14 18:23:40.018 INFO 12440 --- [ntainer#2-0-C-1] c.i.s.l.k.consumer.Demo04Consumer : [onMessage][线程编号:16 消息内容：Demo04Message{id=1647252073}] 2022-03-14 18:23:50.021 ERROR 12440 --- [ntainer#2-0-C-1] essageListenerContainer$ListenerConsumer : Error handler threw an exception

2022-03-14 18:23:50.030 INFO 12440 --- [ntainer#2-0-C-1] c.i.s.l.k.consumer.Demo04Consumer : [onMessage][线程编号:16 消息内容：Demo04Message{id=1647252073}] 2022-03-14 18:23:50.553 INFO 12440 --- [ntainer#2-0-C-1] c.i.s.l.k.consumer.Demo04Consumer : [onMessage][线程编号:16 消息内容：Demo04Message{id=1647252083}] 2022-03-14 18:24:00.569 ERROR 12440 --- [ntainer#2-0-C-1] essageListenerContainer$ListenerConsumer : Error handler threw an exception

Source: yudaocode/SpringBoot-Labs

View original on GitHub View discussion on GitHub