valdar edited a comment on issue #1332:
URL:
https://github.com/apache/camel-kafka-connector/issues/1332#issuecomment-1023261522
Hello @Jelibo,
how are the records that the sink consume produced?
It seems that the header does not adhere with the schema declared:
`schema=Schema{org.apache.kafka.connect.data.Decimal:BYTES}` suggest that
the value should be a bigdecimal encoded as a byte, so to retrieve it one
should do something on the line of: `Decimal.toLogical(schema, (byte[])
header.value())` see
[here](https://github.com/apache/camel-kafka-connector/blob/camel-kafka-connector-0.9.0/core/src/main/java/org/apache/camel/kafkaconnector/CamelSinkTask.java#L233).
Unfortunately `header.value()` returns a `BigDecimal` instead of a `byte[]` as
is declared it should in the provided schema...
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@camel.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
