get schema versions
This commit is contained in:
@@ -4,6 +4,7 @@ package config
|
||||
type Configurations struct {
|
||||
Server ServerConfigurations
|
||||
Kafka KafkaConfigurations
|
||||
SchemaRegistry SchemaRegistryConfigurations
|
||||
}
|
||||
|
||||
|
||||
@@ -22,3 +23,8 @@ type KafkaConfigurations struct {
|
||||
// SASL_Mechanism string
|
||||
// Security_Protocol string
|
||||
}
|
||||
|
||||
type SchemaRegistryConfigurations struct {
|
||||
Endpoint string
|
||||
Topics string
|
||||
}
|
||||
|
||||
@@ -10,3 +10,7 @@ kafka:
|
||||
retry_backoff_ms: 500
|
||||
sasl_user: SASL_USER # read from environment variable
|
||||
sasl_password: SASL_PASSWORD # read from environment variable
|
||||
|
||||
schemaRegistry:
|
||||
endpoint: SCHEMA_REGISTRY_ENDPOINT
|
||||
topics: TOPICS
|
||||
|
||||
Reference in New Issue
Block a user