Logstash to Confluent kafka rest proxy

Elastic Stack Logstash
1

Hi
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

2

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