Skip to content

Commit

Permalink
KAFKA-3946: Protocol guide should say that Produce request acks can o…
Browse files Browse the repository at this point in the history
…nly be 0, 1, or -1

Rephrased the documentation string for the Produce request
Updated the acks configuration docs to state that -1, 0, and 1 are the only allowed values

Author: Mickael Maison <[email protected]>

Reviewers: Gwen Shapira

Closes apache#1680 from mimaison/KAFKA-3946
  • Loading branch information
mimaison authored and gwenshap committed Jul 29, 2016
1 parent 38c65a9 commit 31264f6
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -75,7 +75,7 @@ public class ProducerConfig extends AbstractConfig {
/** <code>acks</code> */
public static final String ACKS_CONFIG = "acks";
private static final String ACKS_DOC = "The number of acknowledgments the producer requires the leader to have received before considering a request complete. This controls the "
+ " durability of records that are sent. The following settings are common: "
+ " durability of records that are sent. The following settings are allowed: "
+ " <ul>"
+ " <li><code>acks=0</code> If set to zero then the producer will not wait for any acknowledgment from the"
+ " server at all. The record will be immediately added to the socket buffer and considered sent. No guarantee can be"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -127,7 +127,7 @@ public class Protocol {

public static final Schema PRODUCE_REQUEST_V0 = new Schema(new Field("acks",
INT16,
"The number of nodes that should replicate the produce before returning. -1 indicates the full ISR."),
"The number of acknowledgments the producer requires the leader to have received before considering a request complete. Allowed values: 0 for no acknowledgments, 1 for only the leader and -1 for the full ISR."),
new Field("timeout", INT32, "The time to await a response in ms."),
new Field("topic_data", new ArrayOf(TOPIC_PRODUCE_DATA_V0)));

Expand Down

0 comments on commit 31264f6

Please sign in to comment.