Thanks for the response. I have removed the deserializer class from the conf file as stated:
input {
kafka {
bootstrap_servers => "kafka1:9911,kafka2:9911,kafka3:9911"
topics => "Elastic_new"
#max_poll_records => "256"
auto_offset_reset => earliest
group_id => "logstash104"
ssl_truststore_location =>"/elasticsearch/logstash7.1.1/kafka_files/kafka.client.truststore.jks"
ssl_truststore_password => "abcdef"
security_protocol => "SSL"
codec => avro {
schema_uri => "/elasticsearch/logstash-7.1.1/kafka_files/ticketInfo.avsc"
tag_on_failure => true
}
}
}
This means the conf will be using the default string deserializer.
When i execute the script, got below output.
{
"ticketObjects" => ,
"@version" => "1",
"@timestamp" => 2019-07-30T15:51:07.676Z
}