# Logstash to Confluent kafka rest proxy

**URL:** <https://discuss.elastic.co/t/logstash-to-confluent-kafka-rest-proxy/96213>\
**Category:** Logstash\
**Created:** [August 8, 2017, 7:47am UTC](https://discuss.elastic.co/t/logstash-to-confluent-kafka-rest-proxy/96213 "2017-08-08T07:47:49Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![rvnrajesh](https://avatars.discourse-cdn.com/v4/letter/r/6de8d8/32.png) [@rvnrajesh](https://discuss.elastic.co/u/rvnrajesh)\
**Post date:** [August 8, 2017, 7:47am UTC](https://discuss.elastic.co/t/logstash-to-confluent-kafka-rest-proxy/96213/1 "2017-08-08T07:47:49Z")

</div>

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](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

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [September 5, 2017, 7:47am UTC](https://discuss.elastic.co/t/logstash-to-confluent-kafka-rest-proxy/96213/2 "2017-09-05T07:47:55Z")

</div>

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