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<K,C,E,A> |
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<K,C,E,A> |
AvroAggregateSerdes.of(String schemaRegistryUrl,
org.apache.avro.Schema aggregateSchema) |