Eugen Iancu created AVRO-2232:
---------------------------------
Summary: Incorrect Decoding
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
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)
