Page History

...

Add ProcessingExceptionHandler as a constructor parameter to GlobalStateUpdateTask and pass it to processor initialisation, mirroring the existing DeserializationExceptionHandler implementation. When invoked, the ProcessingExceptionHandler instance will call the handleError() method (not handle()). This provides automatic backward compatibility through the implementation defined in KIP-1034.

Limitation

In this KIP, DLQ records returned by the handler will be logged with full metadata but NOT sent to Kafka for GlobalKTable processors. This is because GlobalKTable processing does not currently have producer infrastructure. We will cover DLQ in a separate KIP. 

...