[
https://issues.apache.org/jira/browse/KAFKA-12522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-12522.
------------------------------------
Fix Version/s: 3.0.0
Resolution: Fixed
> Cast SMT should allow null value records to pass through
> ---------------------------------------------------------
>
> Key: KAFKA-12522
> URL: https://issues.apache.org/jira/browse/KAFKA-12522
> Project: Kafka
> Issue Type: Bug
> Reporter: Daniel Osvath
> Assignee: Daniel Osvath
> Priority: Minor
> Fix For: 3.0.0
>
>
> The [current Cast
> SMT|https://github.com/apache/kafka/blob/trunk/connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java]
> 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:
> {code:java}
> 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)
> {code}
> 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.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
