If you are setting acks=0 then you don't care about losing data even when the
cluster is up. The only way to get at-least-once is acks=all.
> On Jun 7, 2017, at 1:12 PM, Ankit Jain <ankitjainc...@gmail.com> wrote:
>
> 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
