You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by jk...@apache.org on 2012/10/12 02:15:27 UTC

svn commit: r1397388 - /incubator/kafka/branches/0.8/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLContext.java

Author: jkreps
Date: Fri Oct 12 00:15:26 2012
New Revision: 1397388

URL: http://svn.apache.org/viewvc?rev=1397388&view=rev
Log:
KAFKA-506 Hadoop consumer not advancing to next offset. No review.


Modified:
    incubator/kafka/branches/0.8/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLContext.java

Modified: incubator/kafka/branches/0.8/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLContext.java
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLContext.java?rev=1397388&r1=1397387&r2=1397388&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLContext.java (original)
+++ incubator/kafka/branches/0.8/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLContext.java Fri Oct 12 00:15:26 2012
@@ -205,7 +205,7 @@ public class KafkaETLContext {
             
             key.set(_index, _offset, messageAndOffset.message().checksum());
             
-            _offset = messageAndOffset.offset();  //increase offset
+            _offset = messageAndOffset.nextOffset();  //increase offset
             _count ++;  //increase count
             
             return true;