Module: LogStash::PluginMixins::KafkaAvroSchemaRegistry
- Included in:
- Inputs::Kafka
- Defined in:
- lib/logstash/plugin_mixins/common.rb
Class Method Summary collapse
Instance Method Summary collapse
Class Method Details
.included(base) ⇒ Object
5 6 7 8 |
# File 'lib/logstash/plugin_mixins/common.rb', line 5 def self.included(base) base.extend(self) base.setup_schema_registry_config end |
Instance Method Details
#check_schema_registry_parameters ⇒ Object
27 28 29 30 31 32 33 34 |
# File 'lib/logstash/plugin_mixins/common.rb', line 27 def check_schema_registry_parameters if @schema_registry_url check_for_schema_registry_conflicts @schema_registry_proxy_host, @schema_registry_proxy_port = split_proxy_into_host_and_port(schema_registry_proxy) check_for_key_and_secret check_for_schema_registry_connectivity_and_subjects end end |
#setup_schema_registry_config ⇒ Object
10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 |
# File 'lib/logstash/plugin_mixins/common.rb', line 10 def setup_schema_registry_config # Option to set key to access Schema Registry. config :schema_registry_key, :validate => :string # Option to set secret to access Schema Registry. config :schema_registry_secret, :validate => :password # Option to set the endpoint of the Schema Registry. # This option permit the usage of Avro Kafka deserializer which retrieve the schema of the Avro message from an # instance of schema registry. If this option has value `value_deserializer_class` nor `topics_pattern` could be valued config :schema_registry_url, :validate => :uri # Option to set the proxy of the Schema Registry. # This option permits to define a proxy to be used to reach the schema registry service instance. config :schema_registry_proxy, :validate => :uri end |