From 646ed0a097ef35abdb8e5c35776fdc8f734acc22 Mon Sep 17 00:00:00 2001
From: Ryan Anguiano <ryan.anguiano@gmail.com>
Date: Mon, 25 Sep 2017 14:13:11 -0400
Subject: [PATCH] Update example config

---
 README.md                                   | 4 ++++
 lib/logstash/codecs/avro_schema_registry.rb | 4 ++++
 2 files changed, 8 insertions(+)

diff --git a/README.md b/README.md
index e649c65..63ea2ce 100644
--- a/README.md
+++ b/README.md
@@ -15,6 +15,9 @@ When this codec is used to decode the input, you may pass the following options:
 - ``username`` - optional.
 - ``password`` - optional.
 
+If the input stream is binary encoded, you should use the ``ByteArrayDeserializer``
+in the Kafka input config.
+
 ## Encoding (output)
 
 This codec uses the Confluent schema registry to register a schema and
@@ -45,6 +48,7 @@ input {
     codec => avro_schema_registry {
       endpoint => "http://schemas.example.com"
     }
+    value_deserializer_class => "org.apache.kafka.common.serialization.ByteArrayDeserializer"
   }
 }
 filter {
diff --git a/lib/logstash/codecs/avro_schema_registry.rb b/lib/logstash/codecs/avro_schema_registry.rb
index 51707be..beee4cf 100644
--- a/lib/logstash/codecs/avro_schema_registry.rb
+++ b/lib/logstash/codecs/avro_schema_registry.rb
@@ -30,6 +30,9 @@
 # - ``username`` - optional.
 # - ``password`` - optional.
 #
+# If the input stream is binary encoded, you should use the ``ByteArrayDeserializer``
+# in the Kafka input config.
+#
 # ==== Encoding (output)
 #
 # This codec uses the Confluent schema registry to register a schema and
@@ -60,6 +63,7 @@
 #     codec => avro_schema_registry {
 #       endpoint => "http://schemas.example.com"
 #     }
+#     value_deserializer_class => "org.apache.kafka.common.serialization.ByteArrayDeserializer"
 #   }
 # }
 # filter {