From a919b7d677236727ebf5180e125e2293feb146fa Mon Sep 17 00:00:00 2001
From: Andrey Dyachkov <andrey.dyachkov@gmail.com>
Date: Wed, 23 Oct 2019 11:59:48 +0200
Subject: [PATCH] take only active timelines

---
 .../org/zalando/nakadi/service/timeline/TimelineService.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/java/org/zalando/nakadi/service/timeline/TimelineService.java b/src/main/java/org/zalando/nakadi/service/timeline/TimelineService.java
index db6d7ab386..daccad7740 100644
--- a/src/main/java/org/zalando/nakadi/service/timeline/TimelineService.java
+++ b/src/main/java/org/zalando/nakadi/service/timeline/TimelineService.java
@@ -158,11 +158,11 @@ public void createTimeline(final String eventTypeName, final String storageId)
 
     public void updateTimeLineForRepartition(final EventType eventType, final int partitions)
             throws NakadiBaseException {
-        for (final Timeline timeline : getAllTimelinesOrdered(eventType.getName())) {
+        for (final Timeline timeline : getActiveTimelinesOrdered(eventType.getName())) {
             getTopicRepository(eventType).repartition(timeline.getTopic(), partitions);
         }
 
-        for (final Timeline timeline : getAllTimelinesOrdered(eventType.getName())) {
+        for (final Timeline timeline : getActiveTimelinesOrdered(eventType.getName())) {
             final Timeline.KafkaStoragePosition latestPosition = StaticStorageWorkerFactory.get(timeline)
                     .getLatestPosition(timeline);
             if (latestPosition == null) {