Hi, I have an application that needs to be low latency writing to Kafka.
With the 0.81 producer I set queue.buffering.max.messages to the number of messages I would like to producer to store in memory and queue.enqueue.timeout.ms to 0 to have the producer throw an exception if the server was not keeping up. On 0.9.0.1 I set buffer.memory that provides a similar result as setting queue.buffering.max.messages. But if a set max.block.ms to 0 I get an exception when meta data is retrieved. Is there a way to replicate the same behavior with the 0.9.0.1 producer? Thanks!
