这是一个 Kafka 异常。具体错误信息是:在处理消息时,出现了一个 'ListenerExecutionFailedException' 异常,其中包含了一个 'IllegalArgumentException' 异常,原因是无法找到 'JobTypeEnum' 为代码 20 的枚举值。这个错误可能是由于消息中包含了一个未知的 'JobTypeEnum' 值导致的。

异常堆栈信息:

ERROR o.s.k.l.KafkaMessageListenerContainer$ListenerConsumer - org.springframework.core.log.LogAccessor - [   ] - 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 com.startdt.app.simba.develop.tobreakup.kafka.JobResultFileConsumer.consumerMessage(java.lang.String)' threw exception; nested exception is java.lang.IllegalArgumentException: can not found any JobTypeEnum for code:20; nested exception is java.lang.IllegalArgumentException: can not found any JobTypeEnum for code:20
        at org.springframework.kafka.listener.SeekUtils.seekOrRecover(SeekUtils.java:157)
        at org.springframework.kafka.listener.SeekToCurrentErrorHandler.handle(SeekToCurrentErrorHandler.java:103)
        at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeErrorHandler(KafkaMessageListenerContainer.java:1887)
        at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeRecordListener(KafkaMessageListenerContainer.java:1792)
        at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.doInvokeWithRecords(KafkaMessageListenerContainer.java:1719)
        at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeRecordListener(KafkaMessageListenerContainer.java:1617)
        at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.invokeListener(KafkaMessageListenerContainer.java:1348)
        at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.pollAndInvoke(KafkaMessageListenerContainer.java:1064)
        at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.run(KafkaMessageListenerContainer.java:972)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.lang.Thread.run(Thread.java:748)
Caused by: org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void com.startdt.app.simba.develop.tobreakup.kafka.JobResultFileConsumer.consumerMessage(java.lang.String)' threw exception; nested exception is java.lang.IllegalArgumentException: can not found any JobTypeEnum for code:20; nested exception is java.lang.IllegalArgumentException: can not found any JobTypeEnum for code:20
        at org.springframework.kafka.listener.KafkaMessageListenerContainer$ListenerConsumer.decorateException(KafkaMessageListenerContainer.java:1899)
        ... 10 common frames omitted
Caused by: java.lang.IllegalArgumentException: can not found any JobTypeEnum for code:20

解决方法:

  1. 检查消息内容: 确认消息中发送的 'JobTypeEnum' 代码值是否正确,并确保代码 20 确实存在于 'JobTypeEnum' 枚举中。
  2. 更新代码: 如果代码 20 是一个新的 'JobTypeEnum' 值,需要在代码中添加对应的枚举值,并更新 'JobResultFileConsumer' 中的处理逻辑。
  3. 排查其他错误: 如果确认代码 20 存在且消息内容正确,那么可能是其他错误导致的异常,需要进一步排查。

注意:

  • 此问题通常是由于代码与消息内容不一致导致的,建议仔细检查消息内容和代码逻辑。
  • 如果问题仍然存在,可以参考相关文档或寻求技术支持。
Kafka 异常:JobTypeEnum 找不到代码为 20 的枚举值

原文地址: https://www.cveoy.top/t/topic/oM1W 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录