kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject [1/2] git commit: kafka-994; High level consumer doesn't throw an exception when the message it is trying to fetch exceeds the configured fetch size; patched by Sam Meder; reviewed by Jay Kreps and Jun Rao
Date Fri, 02 Aug 2013 04:31:23 GMT
Updated Branches:
  refs/heads/0.8 b6479e8ad -> ed3e146cf


kafka-994; High level consumer doesn't throw an exception when the message it is trying to
fetch exceeds the configured fetch size; patched by Sam Meder; reviewed by Jay Kreps and Jun
Rao


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/0c8aefc2
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/0c8aefc2
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/0c8aefc2

Branch: refs/heads/0.8
Commit: 0c8aefc251d03ba824cecd6acbcbdf143fdebfb8
Parents: 76d3905
Author: Sam Meder <sam.meder@gmail.com>
Authored: Thu Aug 1 21:30:05 2013 -0700
Committer: Jun Rao <junrao@gmail.com>
Committed: Thu Aug 1 21:30:05 2013 -0700

----------------------------------------------------------------------
 core/src/main/scala/kafka/consumer/PartitionTopicInfo.scala | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/0c8aefc2/core/src/main/scala/kafka/consumer/PartitionTopicInfo.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/consumer/PartitionTopicInfo.scala b/core/src/main/scala/kafka/consumer/PartitionTopicInfo.scala
index 64b702b..9c779ce 100644
--- a/core/src/main/scala/kafka/consumer/PartitionTopicInfo.scala
+++ b/core/src/main/scala/kafka/consumer/PartitionTopicInfo.scala
@@ -62,6 +62,8 @@ class PartitionTopicInfo(val topic: String,
       debug("updated fetch offset of (%s) to %d".format(this, next))
       consumerTopicStats.getConsumerTopicStats(topic).byteRate.mark(size)
       consumerTopicStats.getConsumerAllTopicStats().byteRate.mark(size)
+    } else if(messages.sizeInBytes > 0) {
+      chunkQueue.put(new FetchedDataChunk(messages, this, fetchedOffset.get))
     }
   }
   


Mime
View raw message