Sha256: 9dca8d17c24da5d05d12b31427219d1f71c0c7a3c95d3cf8978d7de3fb336bba
Contents?: true
Size: 807 Bytes
Versions: 2
Compression:
Stored size: 807 Bytes
Contents
Logstash Avro Schema Registry Codec =================== How to Install -------------- ``` bin/plugin install logstash-avro_schema_registry-codec ``` 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
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
logstash-codec-avro_schema_registry-0.9.1 | DEVELOPER.md |
logstash-codec-avro_schema_registry-0.9.0 | DEVELOPER.md |