Kafka New Producer setting acks=2 in 0.8.2.1

2015-05-14 Thread pushkar priyadarshi
Hi,

The documentation for new producer allows passing ack=2(or any other
numeric value) but when i actually pass anything other than 0,1,-1 in
broker log i see following warning.

Client producer-1 from /X.x.x.x:50105 sent a produce request with
request.required.acks of 2, which is now deprecated and will be removed in
next release. Valid values are -1, 0 or 1. Please consult Kafka
documentation for supported and recommended configuration

I have a particular use case where i want replication to be acknowledged by
exactly (replicationFactor -1 ) broker or message publish should fail if
that many Acks are not possible.

regards


Re: Kafka New Producer setting acks=2 in 0.8.2.1

2015-05-14 Thread Guozhang Wang
Hello,

This behavior has been changed since 0.8.2.0, you can find the details in
the following KIP discussion:

https://cwiki.apache.org/confluence/display/KAFKA/KIP-1+-+Remove+support+of+request.required.acks

And the related ticket is KAFKA-1555.

For your use case you could set min.insync.replicas to replicationFactor -
1, see detailed description of this config here:

http://kafka.apache.org/documentation.html#newproducerconfigs

Guozhang

On Thu, May 14, 2015 at 1:40 PM, pushkar priyadarshi 
priyadarshi.push...@gmail.com wrote:

 Hi,

 The documentation for new producer allows passing ack=2(or any other
 numeric value) but when i actually pass anything other than 0,1,-1 in
 broker log i see following warning.

 Client producer-1 from /X.x.x.x:50105 sent a produce request with
 request.required.acks of 2, which is now deprecated and will be removed in
 next release. Valid values are -1, 0 or 1. Please consult Kafka
 documentation for supported and recommended configuration

 I have a particular use case where i want replication to be acknowledged by
 exactly (replicationFactor -1 ) broker or message publish should fail if
 that many Acks are not possible.

 regards




-- 
-- Guozhang


Re: Kafka New Producer setting acks=2 in 0.8.2.1

2015-05-14 Thread pushkar priyadarshi
Thanks Guozhang. It worked .
On Thu, May 14, 2015 at 4:59 PM Guozhang Wang wangg...@gmail.com wrote:

 Hello,

 This behavior has been changed since 0.8.2.0, you can find the details in
 the following KIP discussion:


 https://cwiki.apache.org/confluence/display/KAFKA/KIP-1+-+Remove+support+of+request.required.acks

 And the related ticket is KAFKA-1555.

 For your use case you could set min.insync.replicas to replicationFactor -
 1, see detailed description of this config here:

 http://kafka.apache.org/documentation.html#newproducerconfigs

 Guozhang

 On Thu, May 14, 2015 at 1:40 PM, pushkar priyadarshi 
 priyadarshi.push...@gmail.com wrote:

  Hi,
 
  The documentation for new producer allows passing ack=2(or any other
  numeric value) but when i actually pass anything other than 0,1,-1 in
  broker log i see following warning.
 
  Client producer-1 from /X.x.x.x:50105 sent a produce request with
  request.required.acks of 2, which is now deprecated and will be removed
 in
  next release. Valid values are -1, 0 or 1. Please consult Kafka
  documentation for supported and recommended configuration
 
  I have a particular use case where i want replication to be acknowledged
 by
  exactly (replicationFactor -1 ) broker or message publish should fail if
  that many Acks are not possible.
 
  regards
 



 --
 -- Guozhang