Kafka 消费失败或服务重启后，如何安排重试并保存任务进度？

假设任务发生异常，或者项目重启导致任务中断了，第一怎么识别，第二怎么继续执行这个任务？

我指的是从 Kafka 里面拿到一条消息，需要去处理它。无论调用大模型、算法还是业务库，假设中间出现未知异常，后面怎么重新消费这条数据、继续处理？

假设拿到一条消息，处理时出现了“1除以0”的异常，这条任务就终止了。那 Kafka 里面的消息怎么处理？后续还能不能正常处理这条消息？

Kafka 的消息已经被你的服务端拿到了，它怎么判断这条消息需要重新消费？

无论是异常还是项目重启，怎么识别哪些任务需要重新执行？能不能知道它执行到了哪一步，前面的步骤不用再执行？有没有这样的动作？