Thanks hans.
It would work but producer will start loosing the data even the Cluster is
available.
Thanks
Ankit Jain
On Wed, Jun 7, 2017 at 12:56 PM, Hans Jespersen <h...@confluent.io> wrote:
> Try adding props.put("max.block.ms", "0");
>
> -hans
>
>
>
> > On Jun 7, 2017, at 12:24 PM, Ankit Jain <ankitjainc...@gmail.com> 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
>
>
--
Thanks,
Ankit Jain
