[
https://issues.apache.org/jira/browse/KAFKA-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Marcos Schroh updated KAFKA-19717:
----------------------------------
Description:
When I use the SMT *org.apache.kafka.connect.transforms.InsertHeader* and the
header value is a number, part of the value is dropped. Example:
{code:yaml}
# Insert KafkaHeaders for avro serialization
transforms: insertSpecHeader
transforms.insertSpecHeader.type:
org.apache.kafka.connect.transforms.InsertHeader
transforms.insertSpecHeader.header: "specversion"
transforms.insertSpecHeader.value.literal: "2.0"
{code}
Then, the record is produced with the header *"specversion": "2"*
Is KafkaConnect doing a sort of casting and treating the value as float even
though I am using literal?
was:
When I used the SMT *org.apache.kafka.connect.transforms.InsertHeader* and the
header value is a number, part of the value is dropped. Example:
{code:yaml}
# Insert KafkaHeaders for avro serialization
transforms: insertSpecHeader
transforms.insertSpecHeader.type:
org.apache.kafka.connect.transforms.InsertHeader
transforms.insertSpecHeader.header: "specversion"
transforms.insertSpecHeader.value.literal: "2.0"
{code}
Then, the record is produced with the header *"specversion": "2"*
Is KafkaConnect doing a sort of casting and treating the value as float even
though I am using literal?
> InsertHeader drops part of the value when header value is a number
> ------------------------------------------------------------------
>
> Key: KAFKA-19717
> URL: https://issues.apache.org/jira/browse/KAFKA-19717
> Project: Kafka
> Issue Type: Improvement
> Reporter: Marcos Schroh
> Priority: Major
>
> When I use the SMT *org.apache.kafka.connect.transforms.InsertHeader* and the
> header value is a number, part of the value is dropped. Example:
> {code:yaml}
> # Insert KafkaHeaders for avro serialization
> transforms: insertSpecHeader
> transforms.insertSpecHeader.type:
> org.apache.kafka.connect.transforms.InsertHeader
> transforms.insertSpecHeader.header: "specversion"
> transforms.insertSpecHeader.value.literal: "2.0"
> {code}
> Then, the record is produced with the header *"specversion": "2"*
> Is KafkaConnect doing a sort of casting and treating the value as float even
> though I am using literal?
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
