You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2017/10/27 13:27:32 UTC
kafka git commit: MINOR: Document "high watermark" magic value for
delete records request
Repository: kafka
Updated Branches:
refs/heads/trunk 6197481b8 -> 4ea5fb760
MINOR: Document "high watermark" magic value for delete records request
Author: Paolo Patierno <pp...@live.com>
Reviewers: Ismael Juma <is...@juma.me.uk>
Closes #4119 from ppatierno/minor-delrecords-prot
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/4ea5fb76
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/4ea5fb76
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/4ea5fb76
Branch: refs/heads/trunk
Commit: 4ea5fb760f571fd3e4be14cbd3828f65830a314e
Parents: 6197481
Author: Paolo Patierno <pp...@live.com>
Authored: Fri Oct 27 14:26:50 2017 +0100
Committer: Ismael Juma <is...@juma.me.uk>
Committed: Fri Oct 27 14:26:58 2017 +0100
----------------------------------------------------------------------
.../org/apache/kafka/common/requests/DeleteRecordsRequest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/4ea5fb76/clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsRequest.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsRequest.java b/clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsRequest.java
index 350238e..6467e06 100644
--- a/clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsRequest.java
+++ b/clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsRequest.java
@@ -54,7 +54,7 @@ public class DeleteRecordsRequest extends AbstractRequest {
private static final Schema DELETE_RECORDS_REQUEST_PARTITION_V0 = new Schema(
PARTITION_ID,
- new Field(OFFSET_KEY_NAME, INT64, "The offset before which the messages will be deleted."));
+ new Field(OFFSET_KEY_NAME, INT64, "The offset before which the messages will be deleted. -1 means high-watermark for the partition."));
private static final Schema DELETE_RECORDS_REQUEST_TOPIC_V0 = new Schema(
TOPIC_NAME,