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
:
{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
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
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
e.org"
Sent: Tuesday, April 12, 2016 10:40 AM
Subject: [0.10.1.0-SNAPSHOT] KafkaProducer.close() not committing
Hello,
I'm trying to run the latest master build in github. I've got producer code
like below:
val props = Map( "bootstrap.servers"
Hello,
I'm trying to run the latest master build in github. I've got producer code
like below:
val props = Map( "bootstrap.servers" -> host, "key.serializer" ->
"org.apache.kafka.common.serialization.ByteArraySerializer",
"value.serializer" -> "org.apache.kafka.common.seriali
