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.stal...@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.
