update the method of get current offset

Change-Id: Iad7930c04abf709754c6a6462bf6c49e527ca9d0

diff --git a/depanneur b/depanneur
index 21e75eea777896c65ce4b3af6fe44dd9a46c1ee9..4a946a4fe8b706d5dc3037044925a1cba7e715c9 100755 (executable)
--- a/depanneur
+++ b/depanneur
@@ -2548,13 +2548,19 @@ sub writeToKafka {
        }
 }
 
+sub getCurOffset {
+    my $topic = shift;
+       my $partition = shift;
+       return $consumer->offset_latest($topic, $partition);    
+}
 sub readFromKafka {
     my $cur_level = shift;
     my $partition = 0;
     my @fail_packages;
     my @succeed_packages;
-    my $cur_offset = 0;
+    my $cur_offset = getCurOffset("tizen-unified-status", $partition);
     my $packageNum = @{$packages_level{$cur_level}};
+       info("current offset: $cur_offset");
     while(@fail_packages + @succeed_packages < $packageNum ) {
         my $messages = $consumer->fetch(
             'tizen-unified-status',
@@ -2567,8 +2573,10 @@ sub readFromKafka {
                 $cur_offset = $message->next_offset;
                 if($message->payload eq "failed") {
                     push(@fail_packages, $message->key);
+                                       info("package: $message->key build failed");
                 } else {
                     push(@succeed_packages, $message->key);
+                                       info("package: $message->key build success");
                 }
             } else {
                 info($message->error);