Java producer client timeout?

[Mikael Ståldal <mi...@magine.com>]

I am using the Java producer client, with Callback:
http://kafka.apache.org/082/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html#send(org.apache.kafka.clients.producer.ProducerRecord,%20org.apache.kafka.clients.producer.Callback)

(I am not using the returned Future.)

Is there any way to ensure that the Callback will always be invoked in a
timely fashion? The "timeout.ms" config is not sufficient since it does not
account for network latency, and if all server nodes are down or
unreachable, the network latency is indefinite.

I want to be able to specify some "global" timeout that will be applied not
matter what, a guarantee that the Callback will always be invoked within
that timeout (possibly with an Exception).

-- 
[image: MagineTV]

*Mikael Ståldal*
Senior software developer

*Magine TV*
mikael.staldal@magine.com
Grev Turegatan 3  | 114 46 Stockholm, Sweden  |   www.magine.com

Privileged and/or Confidential Information may be contained in this
message. If you are not the addressee indicated in this message
(or responsible for delivery of the message to such a person), you may not
copy or deliver this message to anyone. In such case,
you should destroy this message and kindly notify the sender by reply
email.