You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2015/08/06 01:31:25 UTC
kafka git commit: MINOR: ConsumerRecords are organized per topic
partition
Repository: kafka
Updated Branches:
refs/heads/trunk 27d499fe6 -> 95c626dc0
MINOR: ConsumerRecords are organized per topic partition
ConsumerRecords has records organized per topic partition, not per topic as ConsumerRecords javadoc suggested.
Author: Stevo Slavić <ss...@gmail.com>
Reviewers: Jason, Guozhang
Closes #92 from sslavic/patch-6 and squashes the following commits:
b08a58d [Stevo Slavić] MINOR: ConsumerRecords are organized per topic partition
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/95c626dc
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/95c626dc
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/95c626dc
Branch: refs/heads/trunk
Commit: 95c626dc04e033c4349e68d47a3bd6e21b77706c
Parents: 27d499f
Author: Stevo Slavić <ss...@gmail.com>
Authored: Wed Aug 5 16:32:25 2015 -0700
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Wed Aug 5 16:32:25 2015 -0700
----------------------------------------------------------------------
.../java/org/apache/kafka/clients/consumer/ConsumerRecords.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/95c626dc/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecords.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecords.java b/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecords.java
index 16a8357..8e6fef4 100644
--- a/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecords.java
+++ b/clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecords.java
@@ -23,8 +23,8 @@ import java.util.Map;
/**
* A container that holds the list {@link ConsumerRecord} per partition for a
- * particular topic. There is one for every topic returned by a
- * {@link Consumer#poll(long)} operation.
+ * particular topic. There is one {@link ConsumerRecord} list for every topic
+ * partition returned by a {@link Consumer#poll(long)} operation.
*/
public class ConsumerRecords<K, V> implements Iterable<ConsumerRecord<K, V>> {
public static final ConsumerRecords<Object, Object> EMPTY =