Re: kafka producer failed

Great to hear that! Cheers! -Yi On Sun, Jul 26, 2015 at 10:53 PM, Job-Selina Wu wrote: > Hi, Yi: > > you are right. After I add the producer.close(); the bug is fixed now. > > Thanks a lot! > > Selina > > On Sun, Jul 26, 2015 at 10:28 PM, Yi Pan wrote: > > > Hi, Selina, > > > > Did you for

Re: kafka producer failed

Hi, Yi: you are right. After I add the producer.close(); the bug is fixed now. Thanks a lot! Selina On Sun, Jul 26, 2015 at 10:28 PM, Yi Pan wrote: > Hi, Selina, > > Did you forget to close your Kafka producer in your Http servlet? If you > create a new Kafka producer in each Http request

Re: kafka producer failed

Hi, Selina, Did you forget to close your Kafka producer in your Http servlet? If you create a new Kafka producer in each Http request and do not close the producer, that might cause this problem. -Yi On Sun, Jul 26, 2015 at 9:25 PM, Job-Selina Wu wrote: > Hi, Yan: > > the kaka.log got *jav

Re: kafka producer failed

Hi, Yan: the kaka.log got *java.io.IOException: Too many open files in system* Some detail list below. Sincerely, Selina [2015-07-26 21:07:01,500] INFO Verifying properties (kafka.utils.VerifiableProperties) [2015-07-26 21:07:01,545] INFO Property broker.id is overridden to 0 (kafka.utils.V

Re: Review Request 35444: SAMZA-692: Scrooge (Scala) Thrift serde

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35444/ --- (Updated July 26, 2015, 11:29 p.m.) Review request for samza. Repository: sam

Re: Review Request 35445: SAMZA-693: Very basic HDFS Producer service for Samza

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35445/ --- (Updated July 26, 2015, 10:47 p.m.) Review request for samza. Repository: sam

Re: Review Request 35445: SAMZA-693: Very basic HDFS Producer service for Samza

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35445/ --- (Updated July 26, 2015, 10:31 p.m.) Review request for samza. Repository: sam

Re: kafka producer failed

You may check the Kafka.log to see what's inside Yan Fang > On Jul 26, 2015, at 2:01 AM, Job-Selina Wu wrote: > > The exception is below: > > kafka.common.FailedToSendMessageException: Failed to send messages after 3 > tries. > kafka.common.FailedToSendMessageException: Failed to send message

Re: Review Request 36768: SAMZA-740: Add ElasticsearchProducer example to samza-hello-samza

> On July 24, 2015, 6:19 p.m., Navina Ramesh wrote: > > It will also be nice to have a tutorial added to the website on how to > > setup and run the example Samza job that uses ElasticSearchProducer. > > Stuart Davidson wrote: > Happy to write something up. Do you want it on the hello-samza

Re: Review Request 36768: SAMZA-740: Add ElasticsearchProducer example to samza-hello-samza

> On July 24, 2015, 6:19 p.m., Navina Ramesh wrote: > > It will also be nice to have a tutorial added to the website on how to > > setup and run the example Samza job that uses ElasticSearchProducer. Happy to write something up. Do you want it on the hello-samza index.md, or a seperate page?

Re: Review Request 36768: SAMZA-740: Add ElasticsearchProducer example to samza-hello-samza

> On July 24, 2015, 6:18 p.m., Navina Ramesh wrote: > > bin/grid-elastic, line 1 > > > > > > Can you make changes to bin/grid by adding options to install > > elastic_search and/or kibana? Code seems redundant. I del

Re: kafka producer failed

The exception is below: kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries. kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries. at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90) at kafka.producer.Producer.se

Re: kafka producer failed

Hi, Yan: My Http Server send message to Kafka. The server.log at deploy/kafka/logs/server.log shown : [2015-07-26 00:33:51,910] INFO Closing socket connection to /127.0.0.1. (kafka.network.Processor) [2015-07-26 00:33:51,984] INFO Closing socket connection to /127.0.0.1. (kafka.network.Pro

Re: kafka producer failed

You are giving the Kafka code and the Samza log, which does not make sense actually... Fang, Yan yanfang...@gmail.com On Sat, Jul 25, 2015 at 10:31 PM, Job-Selina Wu wrote: > Hi, Yi, Navina and Benjamin: > > Thanks a lot to spending your time to help me this issue. > > The configuration