Sha256: 28717d74c8d30675fb21e7be8423b5fb43d2d6a88a57d77c49bcaae772646af8
Contents?: true
Size: 807 Bytes
Versions: 4
Compression:
Stored size: 807 Bytes
Contents
Logstash Avro Schema Registry Codec =================== How to Install -------------- ``` bin/plugin install logstash-codec-avro_schema_registry ``` How to Use ---------- You can use this codec to decode avro messages in a Kafka topic input. Each message must be prefixed with a 5-byte struct containing a magic byte and the schema id. You must pass the endpoint of the schema registry server. Along with the logstash config for reading in messages of this type using the avro codec with the logstash-input-kafka plugin. ### logstash.conf ``` input { kafka { topic_id => 'test_topic' codec => avro_schema_registry { endpoint => 'http://schemas.example.com' } } } output { stdout { codec => rubydebug } } ``` ### Running the setup ``` bin/logstash -f logstash.conf ```
Version data entries
4 entries across 4 versions & 1 rubygems