Update example config

revpoint · Sep 25, 2017 · 646ed0a · 646ed0a
1 parent 99aeefe
commit 646ed0a
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git 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
@@ -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 {