| Package | Description |
|---|---|
| io.simplesource.kafka.serialization.avro |
| Modifier and Type | Method | Description |
|---|---|---|
static <K extends org.apache.avro.generic.GenericRecord,C extends org.apache.avro.generic.GenericRecord,E extends org.apache.avro.generic.GenericRecord,A extends org.apache.avro.generic.GenericRecord> |
AvroAggregateSerdes.of(String schemaRegistryUrl,
boolean useMockSchemaRegistry,
org.apache.avro.Schema aggregateSchema) |
|
static <K extends org.apache.avro.generic.GenericRecord,C extends org.apache.avro.generic.GenericRecord,E extends org.apache.avro.generic.GenericRecord,A extends org.apache.avro.generic.GenericRecord> |
AvroAggregateSerdes.of(String schemaRegistryUrl,
org.apache.avro.Schema aggregateSchema) |
Copyright © 2019. All rights reserved.