fix bug in timeout calculation for consumer auditor shutdown (linkedi…

…n#75)
becketqin · Oct 5, 2017 · 175e758 · 175e758
1 parent 1633d1b
commit 175e758
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/gradle.properties b/gradle.properties
@@ -1,4 +1,4 @@
-version=0.0.12
+version=0.0.13
 org.gradle.daemon=false
 org.gradle.parallel=false
 org.gradle.jvmargs=-Xms512m -Xmx512m

diff --git a/src/main/java/com/linkedin/kafka/clients/auditing/abstractimpl/AbstractAuditor.java b/src/main/java/com/linkedin/kafka/clients/auditing/abstractimpl/AbstractAuditor.java
@@ -152,7 +152,8 @@ public void run() {
         _currentStats.close();
         _nextStats.close();
         _shutdown = true;
-        onClosed(_currentStats, _nextStats, Math.min(0, _shutdownDeadline - System.currentTimeMillis()));
+        long shutdownBudgetRemaining = _shutdownDeadline - System.currentTimeMillis();
+        onClosed(_currentStats, _nextStats, Math.max(0, shutdownBudgetRemaining));
       }
     } else {
       LOG.info("Auto auditing is set to false. Automatic ticking is disabled.");