Browse Source

KAFKA-506 Hadoop consumer not advancing to next offset. No review.

git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1397388 13f79535-47bb-0310-9956-ffa450edef68
0.8.0-beta1-candidate1
Edward Jay Kreps 12 years ago
parent
commit
97d434513f
  1. 2
      contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLContext.java

2
contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLContext.java

@ -205,7 +205,7 @@ public class KafkaETLContext { @@ -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;

Loading…
Cancel
Save