[kafka] branch trunk updated: HOTFIX: fix active task process ratio metric recording

[guozhang]

This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new a0119aa  HOTFIX: fix active task process ratio metric recording
a0119aa is described below

commit a0119aa859ba37f7ed1a2a7c3c00b00672986914
Author: Guozhang Wang <wangg...@gmail.com>
AuthorDate: Thu Apr 16 14:21:36 2020 -0700

    HOTFIX: fix active task process ratio metric recording
---
 .../java/org/apache/kafka/streams/processor/internals/TaskManager.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
 
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
index b725f8a..135a319 100644
--- 
a/streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
+++ 
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
@@ -833,7 +833,7 @@ public class TaskManager {
                 }
                 now = time.milliseconds();
                 totalProcessed += processed;
-                task.recordProcessBatchTime(then - now);
+                task.recordProcessBatchTime(now - then);
             } catch (final TaskMigratedException e) {
                 log.info("Failed to process stream task {} since it got 
migrated to another thread already. " +
                              "Will trigger a new rebalance and close all tasks 
as zombies together.", task.id());