[ https://issues.apache.org/jira/browse/KAFKA-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16870450#comment-16870450 ]
Jagannath commented on KAFKA-8523: ---------------------------------- I am seeing something similar from the ExtractField smt. I think heartbeat messages are not going through the standard ExtractField SMT ``` Caused by: org.apache.kafka.connect.errors.DataException: Only Map objects supported in absence of schema for [field extraction], found: org.apache.kafka.connect.data.Struct debezium-68745ff465-lmslc debezium at org.apache.kafka.connect.transforms.util.Requirements.requireMap(Requirements.java:38) debezium-68745ff465-lmslc debezium at org.apache.kafka.connect.transforms.util.Requirements.requireMapOrNull(Requirements.java:47) debezium-68745ff465-lmslc debezium at org.apache.kafka.connect.transforms.ExtractField.apply(ExtractField.java:57) debezium-68745ff465-lmslc debezium at org.apache.kafka.connect.runtime.TransformationChain.lambda$apply$0(TransformationChain.java:50) debezium-68745ff465-lmslc debezium at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndRetry(RetryWithToleranceOperator.java:128) debezium-68745ff465-lmslc debezium at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:162) ``` > 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 (v7.6.3#76005)