You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Ming-Yen Chung (Jira)" <ji...@apache.org> on 2026/04/10 15:50:00 UTC
[jira] [Assigned] (KAFKA-20433) Fix NPE caused by nonexistent field in HeaderFrom
[ https://issues.apache.org/jira/browse/KAFKA-20433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ming-Yen Chung reassigned KAFKA-20433:
--------------------------------------
Assignee: Ming-Yen Chung (was: Chia-Ping Tsai)
> Fix NPE caused by nonexistent field in HeaderFrom
> -------------------------------------------------
>
> Key: KAFKA-20433
> URL: https://issues.apache.org/jira/browse/KAFKA-20433
> Project: Kafka
> Issue Type: Bug
> Reporter: Chia-Ping Tsai
> Assignee: Ming-Yen Chung
> Priority: Major
>
> {code:java}
> [2026-04-10 15:41:51,450] ERROR [npe-test-sink|task-0] Error encountered in task npe-test-sink-0. Executing stage 'TRANSFORMATION' with class 'org.apache.kafka.connect.transforms.HeaderFrom$Value', where consumed record is {topic='test-topic-npe', partition=5, offset=0, timestamp=1775835710419, timestampType=CreateTime}. (org.apache.kafka.connect.runtime.errors.LogReporter:70)
> java.lang.NullPointerException: Cannot invoke "org.apache.kafka.connect.data.Field.schema()" because the return value of "org.apache.kafka.connect.data.Schema.field(String)" is null
> at org.apache.kafka.connect.transforms.HeaderFrom.applyWithSchema(HeaderFrom.java:145)
> at org.apache.kafka.connect.transforms.HeaderFrom.apply(HeaderFrom.java:117)
> at org.apache.kafka.connect.runtime.TransformationStage.apply(TransformationStage.java:95)
> at org.apache.kafka.connect.runtime.TransformationChain.lambda$apply$0(TransformationChain.java:58)
> at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndRetry(RetryWithToleranceOperator.java:207)
> at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:243)
> at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execute(RetryWithToleranceOperator.java:179)
> at org.apache.kafka.connect.runtime.TransformationChain.apply(TransformationChain.java:58)
> at org.apache.kafka.connect.runtime.WorkerSinkTask.convertAndTransformRecord(WorkerSinkTask.java:585)
> at org.apache.kafka.connect.runtime.WorkerSinkTask.convertMessages(WorkerSinkTask.java:532)
> at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:358)
> at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:261)
> at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:225)
> at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:243)
> at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:298)
> at org.apache.kafka.connect.runtime.isolation.Plugins.lambda$withClassLoader$1(Plugins.java:252)
> at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:545)
> at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:328)
> at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1090)
> at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:614)
> at java.base/java.lang.Thread.run(Thread.java:1474)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)