[
https://issues.apache.org/jira/browse/HUDI-2320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
董可伦 updated HUDI-2320:
----------------------
Description:
When the 'value.serializer' of Kafka Avro Producer is
'org.apache.kafka.common.serialization.ByteArraySerializer',Use the following
settings
{code:java}
--source-class org.apache.hudi.utilities.sources.AvroKafkaSource \
--schemaprovider-class org.apache.hudi.utilities.schema.JdbcbasedSchemaProvider
\
--hoodie-conf
"hoodie.deltastreamer.source.kafka.value.deserializer.class=org.apache.kafka.common.serialization.ByteArrayDeserializer"
{code}
For now,It will throw an exception::
{code:java}
java.lang.ClassCastException: [B cannot be cast to
org.apache.avro.generic.GenericRecord{code}
After
was:
When the 'value.serializer' of Kafka Avro Producer is
'org.apache.kafka.common.serialization.ByteArraySerializer',Use the following
settings
{code:java}
--source-class org.apache.hudi.utilities.sources.AvroKafkaSource \
--schemaprovider-class org.apache.hudi.utilities.schema.JdbcbasedSchemaProvider
\
--hoodie-conf
"hoodie.deltastreamer.source.kafka.value.deserializer.class=org.apache.kafka.common.serialization.ByteArrayDeserializer"
{code}
For now,It will throw an exception::
{code:java}
java.lang.ClassCastException: [B cannot be cast to
org.apache.avro.generic.GenericRecord
{code}
> Add support ByteArrayDeserializer in AvroKafkaSource
> ----------------------------------------------------
>
> Key: HUDI-2320
> URL: https://issues.apache.org/jira/browse/HUDI-2320
> Project: Apache Hudi
> Issue Type: Improvement
> Components: DeltaStreamer
> Reporter: 董可伦
> Assignee: 董可伦
> Priority: Major
> Fix For: 0.10.0
>
>
> When the 'value.serializer' of Kafka Avro Producer is
> 'org.apache.kafka.common.serialization.ByteArraySerializer',Use the following
> settings
> {code:java}
> --source-class org.apache.hudi.utilities.sources.AvroKafkaSource \
> --schemaprovider-class
> org.apache.hudi.utilities.schema.JdbcbasedSchemaProvider \
> --hoodie-conf
> "hoodie.deltastreamer.source.kafka.value.deserializer.class=org.apache.kafka.common.serialization.ByteArrayDeserializer"
> {code}
> For now,It will throw an exception::
> {code:java}
> java.lang.ClassCastException: [B cannot be cast to
> org.apache.avro.generic.GenericRecord{code}
> After
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
