处理含损坏消息的Kafka主题：选REPLACE_THREAD还是SHUTDOWN_CLIENT？

一、损坏消息全量重处理的策略选择 #

直接选CONTINUE作为未捕获异常处理策略就对了。

当流线程碰到没法处理的损坏消息、抛出未捕获异常时，CONTINUE会让线程直接忽略这个异常，接着处理下一条消息——完美匹配你“跳过坏消息、完成全量重处理”的需求。

要注意：这个策略会直接跳过异常对应的消息，不会重试。如果需要留底排查，要么在自定义异常处理器里加日志，要么配合死信队列（DLQ）把坏消息转去专门的主题存着。另外，如果你的应用配置了AT_LEAST_ONCE的处理保证，得确保异常抛出后偏移量能正常提交，不然可能会重复处理坏消息。

二、REPLACE_THREAD和SHUTDOWN_CLIENT的核心差异 #

这俩都是处理流线程异常的策略，但影响范围和适用场景完全不同：

REPLACE_THREAD #

• 只针对出问题的单个线程：哪个线程抛异常就关哪个，然后立刻启个新线程顶上去，其他正常线程该干嘛干嘛，整个应用不会停
• 适合场景：异常是线程局部的偶发问题——比如某线程临时资源泄漏、和Broker的连接闪断，重启单个线程就能恢复，犯不上停整个应用

SHUTDOWN_CLIENT #

• 直接干掉整个客户端：只要有任何一个线程抛异常，所有线程全关，整个应用直接终止
• 适合场景：对数据一致性要求极高的场景——比如金融交易类业务，绝不允许应用带着异常继续跑，怕搞出数据错乱、重复扣费或者丢数据的情况

内容的提问来源于stack exchange，提问作者frblazquez