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