producer/
> KafkaProducer.html#send(org.apache.kafka.clients.producer.
> ProducerRecord,%20org.apache.kafka.clients.producer.Callback)
>
> Let us know if you have follow-up questions.
>
> Alex
>
> On Mon, Aug 8, 2016 at 11:24 AM, Alper Akture
> wrote:
>
> > Thanks
record(s) expired due to timeout while requesting metadata from brokers for
BACCARAT_ROUND_END-0
On Mon, Aug 8, 2016 at 11:34 AM, Alper Akture
wrote:
> I also notice that if I use the send method that takes a callback: public
> Future send(ProducerRecord record, Callback
> callback) {
>
I also notice that if I use the send method that takes a callback:
public Future
send(ProducerRecord record, Callback callback) {
call
that in the onCompletionalso all
On Mon, Aug 8, 2016 at 11:24 AM, Alper Akture
wrote:
> Thanks Alex... using producer props:
>
> {timeout.ms=500, max
,
>
> Alex
>
> On Fri, Aug 5, 2016 at 7:45 PM, Alper Akture
> wrote:
>
> > I'm using 0.10.0.0 and testing some failover scenarios. For dev, i have
> > single kafka node and a zookeeper instance. While sending events to a
> > topic, I shutdown the broker to see
I'm using 0.10.0.0 and testing some failover scenarios. For dev, i have
single kafka node and a zookeeper instance. While sending events to a
topic, I shutdown the broker to see if my failover handling works. However,
I don't see any indication that the send failed, but I do see the
connection refu