kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR: ConsumerRecords are organized per topic partition
Date Wed, 05 Aug 2015 23:31:25 GMT
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ć <sslavic@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ć <sslavic@gmail.com>
Authored: Wed Aug 5 16:32:25 2015 -0700
Committer: Guozhang Wang <wangguoz@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 =


Mime
View raw message