How to do make Avro codec batch push to Kafka?

[elkan1788]

Hi, guys. There I have a request want handle data through Storm blot in batch. But when I integrate with Logstash found that the it push data by line. So is there code avro can support batch push options.

• Request: want to handle data in batch
• Version: 3.0.0
• Operating System: want to handle data in batch
• Config File (output):

output {
    stdout {
        codec => plain {
             format => "%{message}"
       }
    }

    kafka {
        client_id => "logstash-test"
        bootstrap_servers => "xxx:9092,xxx:9093"
        topic_id => "logstash-test"
        compression_type => "snappy"
        retries => 5

        codec => avro {
            schema_uri => "/root/User.avsc"
        }
    }
}