# Elasticsearch-river-kafka can not work **URL:** \ **Category:** Elasticsearch\ **Created:** [March 31, 2014, 8:30am UTC](https://discuss.elastic.co/t/elasticsearch-river-kafka-can-not-work/16708 "2014-03-31T08:30:34Z")\ **Posts on this page:** 2\ **Page:** 1
**Author:** ![xiaomingfeng99](https://avatars.discourse-cdn.com/v4/letter/x/f14d63/32.png) [@xiaomingfeng99](https://discuss.elastic.co/u/xiaomingfeng99)\ **Post date:** [March 31, 2014, 8:30am UTC](https://discuss.elastic.co/t/elasticsearch-river-kafka-can-not-work/16708/1 "2014-03-31T08:30:34Z")
Hi, I installed elasticsearch-river-kafka and restart the elasticsearch. when I create a new river, it cat not started. There are some error message in the elasticsearch.log: [2014-03-31 16:11:26,613][INFO][org.apache.zookeeper.ClientCnxn] Opening socket connection to server /172.16.241.225:2181 [2014-03-31 16:11:31,842][INFO][org.apache.zookeeper.ClientCnxn] Socket connection established to 172.16.241.225/172.16.241.225:2181, initiating session [2014-03-31 16:11:31,854][INFO][org.apache.zookeeper.ClientCnxn] Session establishment complete on server 172.16.241.225/172.16.241.225:2181, sessionid = 0x145172db3120005, negotiated timeout = 6000 [2014-03-31 16:11:32,410][ERROR][river.kafka] [Jazz] [kafka][my\_kafka\_river\_0] Unexpected Error occurred com.timgroup.statsd.StatsDClientException: Failed to start StatsD client at com.timgroup.statsd.StatsDClient.(StatsDClient.java:109) at com.timgroup.statsd.StatsDClient.(StatsDClient.java:76) at org.elasticsearch.river.kafka.StatsReporter.(StatsReporter.java:37) at org.elasticsearch.river.kafka.KafkaRiver$KafkaRiverWorker.initStatsd(KafkaRiver.java:144) at org.elasticsearch.river.kafka.KafkaRiver$KafkaRiverWorker.(KafkaRiver.java:139) at org.elasticsearch.river.kafka.KafkaRiver.start(KafkaRiver.java:68) at org.elasticsearch.river.RiversService.createRiver(RiversService.java:146) at org.elasticsearch.river.RiversService$ApplyRivers$2.onResponse(RiversService.java:270) at org.elasticsearch.river.RiversService$ApplyRivers$2.onResponse(RiversService.java:264) at org.elasticsearch.action.support.TransportAction$ThreadedActionListener$1.run(TransportAction.java:87) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:744) Caused by: java.net.SocketException: Unresolved address at java.net.DatagramSocket.connect(DatagramSocket.java:477) at com.timgroup.statsd.StatsDClient.(StatsDClient.java:107) ... 12 more [2014-03-31 16:11:32,413][WARN][river] [Jazz] failed to create river [kafka][my\_kafka\_river\_0] java.lang.RuntimeException: com.timgroup.statsd.StatsDClientException: Failed to start StatsD client at org.elasticsearch.river.kafka.KafkaRiver.start(KafkaRiver.java:74) at org.elasticsearch.river.RiversService.createRiver(RiversService.java:146) at org.elasticsearch.river.RiversService$ApplyRivers$2.onResponse(RiversService.java:270) at org.elasticsearch.river.RiversService$ApplyRivers$2.onResponse(RiversService.java:264) at org.elasticsearch.action.support.TransportAction$ThreadedActionListener$1.run(TransportAction.java:87) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:744) Caused by: com.timgroup.statsd.StatsDClientException: Failed to start StatsD client at com.timgroup.statsd.StatsDClient.(StatsDClient.java:109) at com.timgroup.statsd.StatsDClient.(StatsDClient.java:76) at org.elasticsearch.river.kafka.StatsReporter.(StatsReporter.java:37) at org.elasticsearch.river.kafka.KafkaRiver$KafkaRiverWorker.initStatsd(KafkaRiver.java:144) at org.elasticsearch.river.kafka.KafkaRiver$KafkaRiverWorker.(KafkaRiver.java:139) at org.elasticsearch.river.kafka.KafkaRiver.start(KafkaRiver.java:68) ... 7 more Caused by: java.net.SocketException: Unresolved address at java.net.DatagramSocket.connect(DatagramSocket.java:477) at com.timgroup.statsd.StatsDClient.(StatsDClient.java:107) ... 12 more Creating the Kafka river Command： [root@CNC-JN-O-3Q2 es-kafka]# curl -XPUT '172.16.241.225:9200/\_river/my\_kafka\_river\_0/\_meta' -d '{ "type" : "kafka", "kafka" : { "broker\_host" : "172.16.241.225", "message\_handler\_factory\_class" : "org.elasticsearch.river.kafka.JsonMessageHandlerFactory", "zookeeper" : "172.16.241.225", "topic" : "my\_topic", "partition" : "0", "broker\_port" : 9092 }, "index" : { "bulk\_size\_bytes" : 10000, "bulk\_timeout" : "1000ms" }, "statsd":{ "prefix": "es-kafka-river", "host": "ambassador", "port": "8125" } }' {"ok":true,"\_index":"\_river","\_type":"my\_kafka\_river\_0","\_id":"\_meta","\_version":1}[root@CNC-JN-O-3Q2 es-kafka]# [root@CNC-JN-O-3Q2 es-kafka]# what is missing for it? how can I to do? Thanks, Arthur -- 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). To view this discussion on the web visit [https://groups.google.com/d/msgid/elasticsearch/2a3c2925-a052-4d0e-816b-04389b33e7c1%40googlegroups.com](https://groups.google.com/d/msgid/elasticsearch/2a3c2925-a052-4d0e-816b-04389b33e7c1%40googlegroups.com). For more options, visit [https://groups.google.com/d/optout](https://groups.google.com/d/optout). ---
**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, 1:39am UTC](https://discuss.elastic.co/t/elasticsearch-river-kafka-can-not-work/16708/2 "2017-07-06T01:39:28Z")