54.7. 消费者错误处理

虽然 kafka consumer 正在轮询来自 kafka 代理的消息，但可能会出现错误。本节描述了发生的情况以及您可以配置的内容。

在调用 Kafka 轮询 API 时，消费者可能会抛出异常。例如，如果消息因为无效数据而无法序列化，以及许多其他错误。这些错误采用 KafkaException 的形式，可以是 retry 或 not。可以重试的例外(RetriableException)将再次重试（间隔出现轮询超时）。所有其他类型的异常会根据 pollOnError 配置进行处理。此配置具有以下值：

默认值为 ERROR_HANDLER，它允许 Camel 的错误处理程序（若有配置）处理原因异常。然后，继续轮询下一个消息。这个行为与 Camel 组件拥有的 bridgeErrorHandler 选项类似。

对于高级控制，可以在组件级别上配置 org.apache.camel.component.kafka.PollExceptionStrategy 的自定义实现，它允许控制上述策略出现哪些例外情况。