Thanks Alex... using producer props:
{timeout.ms=500, max.block.ms=500, request.timeout.ms=500,
bootstrap.servers=localhost:9092,
serializer.class=kafka.serializer.StringEncoder,
value.serializer=org.apache.kafka.common.serialization.StringSerializer,
metadata.fetch.timeout.ms=500,
key.serializer=org.apache.kafka.common.serialization.StringSerializer}
On Mon, Aug 8, 2016 at 9:21 AM, Alex Loddengaard <a...@confluent.io> wrote:
> Hi Alper, can you share your producer config -- the Properties object? We
> need to learn more to help you understand the behavior you're observing.
>
> Thanks,
>
> Alex
>
> On Fri, Aug 5, 2016 at 7:45 PM, Alper Akture <al...@goldenratstudios.com>
> 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 if my failover handling works.
> However,
> > I don't see any indication that the send failed, but I do see the
> > connection refused errors logged at debug. What is the standard way to
> > detect a message send failure, and handle it for offline processing
> later?
> >
> > Here's the debug output I see:
> >
> > 19:20:00.906 [kafka-producer-network-thread | producer-1] DEBUG
> > org.apache.kafka.clients.NetworkClient - Initialize connection to node
> -1
> > for sending metadata request
> > 19:20:00.906 [kafka-producer-network-thread | producer-1] DEBUG
> > org.apache.kafka.clients.NetworkClient - Initiating connection to node
> -1
> > at localhost:9092.
> > 19:20:00.907 [kafka-producer-network-thread | producer-1] DEBUG
> > org.apache.kafka.common.network.Selector - Connection with localhost/
> > 127.0.0.1 disconnected
> > java.net.ConnectException: Connection refused
> > at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> ~[?:1.8.0_66]
> > at sun.nio.ch.SocketChannelImpl.finishConnect(
> SocketChannelImpl.java:717)
> > ~[?:1.8.0_66]
> > at
> > org.apache.kafka.common.network.PlaintextTransportLayer.finishConnect(
> > PlaintextTransportLayer.java:51)
> > ~[kafka-clients-0.10.0.0.jar:?]
> > at
> > org.apache.kafka.common.network.KafkaChannel.finishConnect(KafkaChannel.
> > java:73)
> > ~[kafka-clients-0.10.0.0.jar:?]
> > at
> > org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.
> > java:309)
> > [kafka-clients-0.10.0.0.jar:?]
> > at org.apache.kafka.common.network.Selector.poll(Selector.java:283)
> > [kafka-clients-0.10.0.0.jar:?]
> > at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260)
> > [kafka-clients-0.10.0.0.jar:?]
> > at org.apache.kafka.clients.producer.internals.Sender.run(
> Sender.java:229)
> > [kafka-clients-0.10.0.0.jar:?]
> > at org.apache.kafka.clients.producer.internals.Sender.run(
> Sender.java:134)
> > [kafka-clients-0.10.0.0.jar:?]
> > at java.lang.Thread.run(Thread.java:745) [?:1.8.0_66]
> > 19:20:00.907 [kafka-producer-network-thread | producer-1] DEBUG
> > org.apache.kafka.clients.NetworkClient - Node -1 disconnected.
> > 19:20:00.907 [kafka-producer-network-thread | producer-1] DEBUG
> > org.apache.kafka.clients.NetworkClient - Give up sending metadata
> request
> > since no node is available
> >
>
