Try adding props.put("max.block.ms", "0");
-hans
> On Jun 7, 2017, at 12:24 PM, Ankit Jain <[email protected]> wrote:
>
> Hi,
>
> We want to use the non blocking Kafka producer. The producer thread should
> not block if the Kafka is cluster is down or not reachable.
>
> Currently, we are setting following properties but the Producer thread is
> still blocking if the Kafka cluster goes gown or unreachable.
>
> * props.put("block.on.buffer.full", "false");*
> * props.put("acks", "0");*
>
> --
> Thanks
