# River plugin just run in one node **URL:** \ **Category:** Elasticsearch\ **Created:** [March 22, 2013, 5:56am UTC](https://discuss.elastic.co/t/river-plugin-just-run-in-one-node/11256 "2013-03-22T05:56:13Z")\ **Posts on this page:** 4\ **Page:** 1
**Author:** ![xiaoliang\_tian](https://avatars.discourse-cdn.com/v4/letter/x/a9a28c/32.png) [@xiaoliang\_tian](https://discuss.elastic.co/u/xiaoliang_tian)\ **Post date:** [March 22, 2013, 5:56am UTC](https://discuss.elastic.co/t/river-plugin-just-run-in-one-node/11256/1 "2013-03-22T05:56:13Z")
I have 10 ES servers one of them is master server ,others connect to it here is the slave configuration discovery.zen.ping.unicast.hosts: [10.165.4.160] for master configuration #discovery.zen.ping.unicast.hosts: [] other configurations is all default value I init river in every server: curl -XPUT 'localhost:9200/\_river/test/\_meta' -d '{"type" : "kafka","kafka" : {"zk.connect" : "127.0.0.1:2181","topic":"log"},"index" : {"bulk\_size" : 100}}' there is just one consumer thread running on one single server,and kafka partition is 10,So when I create 10 rivers in each of servers, all of 10 consumer should run in server But just master node consume messages from kafka... Please help me -- 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](mailto:elasticsearch+unsubscribe@googlegroups.com). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). ---
**Author:** ![xiaoliang\_tian](https://avatars.discourse-cdn.com/v4/letter/x/a9a28c/32.png) [@xiaoliang\_tian](https://discuss.elastic.co/u/xiaoliang_tian)\ **Post date:** [March 22, 2013, 6:06am UTC](https://discuss.elastic.co/t/river-plugin-just-run-in-one-node/11256/2 "2013-03-22T06:06:41Z")
I execute this command in each od server > curl -XPUT 'localhost:9200/\_river/test/\_meta' -d '{"type" : > "kafka","kafka" : {"zk.connect" : "127.0.0.1:2181","topic":"log"},"index" > : {"bulk\_size" : 100}}' then I execute curl -XGET 'localhost:9200/\_river/es/\_status' the resut is : {"\_index":"\_river","\_type":"es","\_id":"\_status","\_version":1,"exists":true, "\_source" : {"ok":true,"node":{"id":"i9C1lDB9RMKdXw-6osH1Yg","name":"Frey","transport\_address":"inet[/10.165.4.160:9300]"}}} 10.165.4.160 is master ip. how can I create 10 rive(consumer) in this cluster -- 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](mailto:elasticsearch+unsubscribe@googlegroups.com). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). ---
**Author:** ![dadoonet](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/dadoonet/32/137187_2.png) [@dadoonet](https://discuss.elastic.co/u/dadoonet)\ **Post date:** [March 22, 2013, 7:09am UTC](https://discuss.elastic.co/t/river-plugin-just-run-in-one-node/11256/3 "2013-03-22T07:09:08Z")
By design, there's only one river instance running per cluster. There is a replica of the river in case of node failure: another node will relaunch the river. But the replica is not _running_. That said, you could ask for an option in rivers to have more than one instance running in the cluster. I did not look at the river source code and don't know yet if we can do it or not. Open an issue? -- David Pilato | Technical Advocate | [Elasticsearch.com](http://Elasticsearch.com) @dadoonet | @elasticsearchfr | @scrutmydocs Le 22 mars 2013 à 07:06, 田晓亮 [xiaoliang.tian@gmail.com](mailto:xiaoliang.tian@gmail.com) a écrit : > I execute this command in each od server > > curl -XPUT 'localhost:9200/\_river/test/\_meta' -d '{"type" : "kafka","kafka" : {"zk.connect" : "127.0.0.1:2181","topic":"log"},"index" : {"bulk\_size" : 100}}' > > then I execute > curl -XGET 'localhost:9200/\_river/es/\_status' > the resut is : > {"\_index":"\_river","\_type":"es","\_id":"\_status","\_version":1,"exists":true, "\_source" : {"ok":true,"node":{"id":"i9C1lDB9RMKdXw-6osH1Yg","name":"Frey","transport\_address":"inet[/10.165.4.160:9300]"}}} > > 10.165.4.160 is master ip. > how can I create 10 rive(consumer) in this cluster > > -- > 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](mailto:elasticsearch+unsubscribe@googlegroups.com). > For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). -- 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](mailto:elasticsearch+unsubscribe@googlegroups.com). For more options, visit [https://groups.google.com/groups/opt\_out](https://groups.google.com/groups/opt_out). ---
**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\ **Post date:** [July 6, 2017, 2:45am UTC](https://discuss.elastic.co/t/river-plugin-just-run-in-one-node/11256/4 "2017-07-06T02:45:11Z")