Merge pull request #1109 from zalando/repartitioning-fix

take only active timelines
zalando · Oct 23, 2019 · 96a6967 · 96a6967
2 parents 3c20ea2 + a919b7d
commit 96a6967
Showing 1 changed file with 2 additions and 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
@@ -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) {