Open shah-smit opened 4 years ago
codec => avro_schema_registry { schema_uri => "/usr/local/etc/logstash/customer.avsc" register_schema => true subject_name => "customer-avro" endpoint => "http://127.0.0.1:8081" } value_deserializer_class => "org.apache.kafka.common.serialization.ByteArrayDeserializer"
json { source => "message" }
https://gquintana.github.io/2016/09/07/Testing-Logstash-configuration.html
codec => avro_schema_registry { schema_uri => "/usr/local/etc/logstash/customer.avsc" register_schema => true subject_name => "customer-avro" endpoint => "http://127.0.0.1:8081" } value_deserializer_class => "org.apache.kafka.common.serialization.ByteArrayDeserializer"