Data from rabbitmq river not getting indexed

Elastic Stack Elasticsearch
1

Hi,

I am a newbie to Elasticsearch, RabbitMQ as well . Actually i'm trying to
connect Elasticsearch and RabbitMQ using the river plugin
(https://github.com/elasticsearch/elasticsearch-river-rabbitmq).
I have binded exchange which elastic search is creating with the exchange
which my application is creating , exchange type as *fanout * .
when i am putting messages(which are in bulk api format) to the
exchange(exchange created by the application) , messages are neither
getting indexed in ES nor throwing some exception or error.
when i am putting messages which are not in bulk api format elastic search
is throwing : *org.elasticsearch.ElasticSearchParseException: Failed to
derive xcontent from org.elasticsearch.common.bytes.BytesArray@e1f1d071 *

Can any one please help out, with any documentation or let me know where i
have done wrong.

meta data for connecting to RabbitMQ river : {
"type" : "rabbitmq",
"rabbitmq" : {
"host" : "localhost",
"port" : 5672,
"user" : "guest",
"pass" : "guest",
"vhost" : "/",
"queue" : "elasticsearch",
"exchange" : "elasticsearch",

    "exchange_declare" : true,
    "exchange_type" : "fanout",
    "exchange_durable" : true,
    "queue_declare" : true,
    "queue_bind" : true,
    "queue_durable" : true,
    "queue_auto_delete" : false,
    "heartbeat" : "30m"
},
"index" : {
    "bulk_size" : 100,
    "bulk_timeout" : "100ms",
    "ordered" : false
}

}

Please help!!!

--
You received this message because you are subscribed to the Google Groups "elasticsearch" group.
To unsubscribe from this group and stop receiving emails from it, send an email to elasticsearch+unsubscribe@googlegroups.com.
For more options, visit https://groups.google.com/groups/opt_out.