You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Kunal Gupta (Jira)" <ji...@apache.org> on 2021/12/22 13:04:00 UTC

[jira] [Commented] (KAFKA-12522) Cast SMT should allow null value records to pass through

    [ https://issues.apache.org/jira/browse/KAFKA-12522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17463795#comment-17463795 ] 

Kunal Gupta commented on KAFKA-12522:
-------------------------------------

Can anyone please paste here the final resolved jar file link for this 12522 issue of Kafka.

> 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.20.1#820001)