Logstash to Confluent kafka rest proxy

I'd like to use Confluent's REST proxy to push the json data to kafka. But according to the documentation http://docs.confluent.io/3.0.0/kafka-rest/docs/intro.html#produce-and-consume-json-messages7 I'd need to wrap the json messages like that :

records: [ {
value: {---> json input data----> }
, ...]
Is there any filter that would allow me to do so ? or do I need to write another plugin? i' am trying to send the data through http output plugin

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.