(store: &SchemaStore, fp: Fingerprint, reader_schema: &AvroSchema)
| 1576 | } |
| 1577 | |
| 1578 | fn make_decoder(store: &SchemaStore, fp: Fingerprint, reader_schema: &AvroSchema) -> Decoder { |
| 1579 | ReaderBuilder::new() |
| 1580 | .with_batch_size(8) |
| 1581 | .with_reader_schema(reader_schema.clone()) |
| 1582 | .with_writer_schema_store(store.clone()) |
| 1583 | .with_active_fingerprint(fp) |
| 1584 | .build_decoder() |
| 1585 | .expect("decoder") |
| 1586 | } |
| 1587 | |
| 1588 | fn make_id_prefix(id: u32, additional: usize) -> Vec<u8> { |
| 1589 | let capacity = CONFLUENT_MAGIC.len() + size_of::<u32>() + additional; |