Sha256: 30c1d7e7e1eee3d5782a98309839cb9e814d292cf5e0f447e0b60daf204b39b8
Contents?: true
Size: 1.11 KB
Versions: 17
Compression:
Stored size: 1.11 KB
Contents
Logstash Avro Codec
===================
How to Install
--------------
```
bin/plugin install logstash-avro-codec
```
How to Use
----------
You can use this codec to decode avro messages
in a Kafka topic input.
Here is an example schema for tweets.
### tweet.avsc
```
{
"type" : "record",
"name" : "twitter_schema",
"namespace" : "com.miguno.avro",
"fields" : [ {
"name" : "username",
"type" : "string",
"doc" : "Name of the user account on Twitter.com"
}, {
"name" : "tweet",
"type" : "string",
"doc" : "The content of the user's Twitter message"
}, {
"name" : "timestamp",
"type" : "long",
"doc" : "Unix epoch time in seconds"
} ],
"doc:" : "A basic schema for storing Twitter messages"
}
```
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_uri => 'tweet.avsc'
}
}
}
output {
stdout {
codec => rubydebug
}
}
```
### Running the setup
```
bin/logstash -f logstash.conf
```
Version data entries
17 entries across 17 versions & 1 rubygems