Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SchemaRegistryOptions ¶
type SchemaRegistryOptions struct {
SchemaBackend string `long:"schema-backend" default:"consul" description:"Avro schema registry to use. Can be 'consul', 'kafka' or 'noop'."`
Kafka struct {
Topic string `long:"schema-kafka-topic" default:"avro_schema" description:"Topic to write schema descriptions to"`
ReplFactor int `` /* 140-byte string literal not displayed */
}
// contains filtered or unexported fields
}
func (*SchemaRegistryOptions) Initialize ¶
func (opts *SchemaRegistryOptions) Initialize(kafka *startup_kafka.KafkaOptions, consul *startup_consul.ConsulOptions)
func (*SchemaRegistryOptions) SchemaRegistry ¶
func (opts *SchemaRegistryOptions) SchemaRegistry() schema.Registry
Click to show internal directories.
Click to hide internal directories.