[
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)
