[KAFKA-12522] Cast SMT should allow null value records to pass through

• Type: Bug
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 3.0.0
• Assignee: Daniel Osvath
• Reporter: Daniel Osvath
• Created: 22/Mar/21 22:27
• Updated: 22/Dec/21 13:03
• Resolved: 21/May/21 10:35

Description

The current Cast SMT fails on a null record value (or a null record key), which is problematic for tombstone records. When a tombstone record reaches the transformation the error below is thrown:

Caused by: org.apache.kafka.connect.errors.DataException: Only Map objects supported in absence of schema for [cast types], found: null
at org.apache.kafka.connect.transforms.util.Requirements.requireMap(Requirements.java:38)

Null values should instead be allowed to pass through as there is no cast transformation to be done, with the benefit of allowing the connector to handle the tombstone records as intended.

Issue Links

• links to: GitHub Pull Request #10375