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

[jira] [Commented] (KAFKA-8523) InsertField transformation fails when encountering tombstone event

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

Frederic Tardif commented on KAFKA-8523:
----------------------------------------

I believe an option should be exposed to configure the behaviour in order to either pass the null value unmodified or to apply the insert on an empty map. 

> InsertField transformation fails when encountering tombstone event
> ------------------------------------------------------------------
>
>                 Key: KAFKA-8523
>                 URL: https://issues.apache.org/jira/browse/KAFKA-8523
>             Project: Kafka
>          Issue Type: Bug
>          Components: KafkaConnect
>            Reporter: Gunnar Morling
>            Priority: Major
>
> When applying the {{InsertField}} transformation to a tombstone event, an exception is raised:
> {code}
> org.apache.kafka.connect.errors.DataException: Only Map objects supported in absence of schema for [field insertion], found: null
> 	at org.apache.kafka.connect.transforms.util.Requirements.requireMap(Requirements.java:38)
> 	at org.apache.kafka.connect.transforms.InsertField.applySchemaless(InsertField.java:138)
> 	at org.apache.kafka.connect.transforms.InsertField.apply(InsertField.java:131)
> 	at org.apache.kafka.connect.transforms.InsertFieldTest.tombstone(InsertFieldTest.java:128)
> {code}
> AFAICS, the transform can still be made working in in this case by simply building up a new value map from scratch.



--
This message was sent by Atlassian Jira
(v8.3.2#803003)