Re: [0.10.1.0-SNAPSHOT] KafkaProducer.close() not committing

2016-04-13 Thread Greg Zoller
t; Sent: Wednesday, April 13, 2016 9:08 PM Subject: Re: [0.10.1.0-SNAPSHOT] KafkaProducer.close() not committing I did and now it hangs on the first send.  Here's my output: (hopefully won't destroy formatting).The "::: Writing 1 :::" should output a line like that for each o

Re: [0.10.1.0-SNAPSHOT] KafkaProducer.close() not committing

2016-04-13 Thread Greg Zoller
: {lowercaseStrings=LEADER_NOT_AVAILABLE}org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 59860 ms. From: Ismael Juma To: users@kafka.apache.org; Greg Zoller Sent: Wednesday, April 13, 2016 5:54 PM Subject: Re: [0.10.1.0-SNAPSHOT] KafkaProducer.close() not co

Re: [0.10.1.0-SNAPSHOT] KafkaProducer.close() not committing

2016-04-13 Thread Ismael Juma
gt; gwzol...@yahoo.com> > Sent: Tuesday, April 12, 2016 11:49 AM > Subject: Re: [0.10.1.0-SNAPSHOT] KafkaProducer.close() not committing > > Sorry the formatting was all messed up.I re-tested this code with 0.9.0.1 > and it worked fine--KafkaProducer closed and committed the numb

Re: [0.10.1.0-SNAPSHOT] KafkaProducer.close() not committing

2016-04-13 Thread Greg Zoller
oller To: "users@kafka.apache.org" ; Greg Zoller Sent: Tuesday, April 12, 2016 11:49 AM Subject: Re: [0.10.1.0-SNAPSHOT] KafkaProducer.close() not committing Sorry the formatting was all messed up.I re-tested this code with 0.9.0.1 and it worked fine--KafkaProducer closed an

Re: [0.10.1.0-SNAPSHOT] KafkaProducer.close() not committing

2016-04-12 Thread Greg Zoller
Sorry the formatting was all messed up.I re-tested this code with 0.9.0.1 and it worked fine--KafkaProducer closed and committed the number of records expected into the partitions. So this seems like a SNAPSHOT issue.  Will continue looking. From: Greg Zoller To: "users@kafka.apache.org"