From 96cab04040bd74afbcf0011664be1c2348972c5e Mon Sep 17 00:00:00 2001
From: Liquan Pei <liquanpei@gmail.com>
Date: Tue, 22 Sep 2015 17:15:13 -0700
Subject: [PATCH] Should stop offset backing store in Worker's stop method

---
 .../src/main/java/org/apache/kafka/copycat/runtime/Worker.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/copycat/runtime/src/main/java/org/apache/kafka/copycat/runtime/Worker.java b/copycat/runtime/src/main/java/org/apache/kafka/copycat/runtime/Worker.java
index 6cbce0b251e3e..aeb09a6c637e2 100644
--- a/copycat/runtime/src/main/java/org/apache/kafka/copycat/runtime/Worker.java
+++ b/copycat/runtime/src/main/java/org/apache/kafka/copycat/runtime/Worker.java
@@ -132,7 +132,7 @@ public void stop() {
         long timeoutMs = limit - time.milliseconds();
         sourceTaskOffsetCommitter.close(timeoutMs);
 
-        offsetBackingStore.start();
+        offsetBackingStore.stop();
 
         log.info("Worker stopped");
     }