[
https://issues.apache.org/jira/browse/AVRO-2232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Eugen Iancu updated AVRO-2232:
------------------------------
Summary: Incorrect Decoding from Oracle GoldenGate (was: Incorrect
Decoding)
> Incorrect Decoding from Oracle GoldenGate
> -----------------------------------------
>
> Key: AVRO-2232
> URL: https://issues.apache.org/jira/browse/AVRO-2232
> Project: Avro
> Issue Type: Bug
> Affects Versions: 1.8.2
> Reporter: Eugen Iancu
> Priority: Major
> Attachments: avro_vim.JPG, generic_wrapper.avsc, kafka2.out
>
>
> Trying to decode the attached binary file with the attached avro schema, in a
> very generic approach in Scala:
> def decode(message: Array[Byte], schemaString: String): GenericRecord = {
> val schema: Schema = new Schema.Parser().parse(schemaString) val reader:
> DatumReader[GenericRecord] = new SpecificDatumReader[GenericRecord](schema)
> val decoder: Decoder = DecoderFactory.get().binaryDecoder(message, null)
> reader.read(null, decoder)
> }
>
> Resulting Generic Record:
> Decoded data: {"table_name": "APP_HDP_TEST.TESTNUM", "schema_fingerprint":
> 1679940236203361734, "payload": {"bytes": "(APP_HDP_TEST.TESTNUMI42018-09-27
> 13:27:57.16162142018-09-28T08:45:01.038000(00000000130000338537ID
>
> Attached binary file and schema are provided by Oracle GoldenGate and we
> expect to see information for both TESTNUM and TESTID tables in the decoded
> message (as in the attached screenshot from vim of the binary file).
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
