Merge pull request #1109 from zalando/repartitioning-fix

take only active timelines

Author: ferbncode

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) {