From 97d434513fe949005ae87d7c0fb3912708f3f728 Mon Sep 17 00:00:00 2001
From: Edward Jay Kreps <jkreps@apache.org>
Date: Fri, 12 Oct 2012 00:15:26 +0000
Subject: [PATCH] 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
---
 .../src/main/java/kafka/etl/KafkaETLContext.java                | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLContext.java b/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLContext.java
index bca175789a4..949816924ec 100644
--- a/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLContext.java
+++ b/contrib/hadoop-consumer/src/main/java/kafka/etl/KafkaETLContext.java
@@ -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;