Skip to content
This repository was archived by the owner on Jun 7, 2024. It is now read-only.

Commit a919b7d

Browse files
committed
take only active timelines
1 parent 3c20ea2 commit a919b7d

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/main/java/org/zalando/nakadi/service/timeline/TimelineService.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -158,11 +158,11 @@ public void createTimeline(final String eventTypeName, final String storageId)
158158

159159
public void updateTimeLineForRepartition(final EventType eventType, final int partitions)
160160
throws NakadiBaseException {
161-
for (final Timeline timeline : getAllTimelinesOrdered(eventType.getName())) {
161+
for (final Timeline timeline : getActiveTimelinesOrdered(eventType.getName())) {
162162
getTopicRepository(eventType).repartition(timeline.getTopic(), partitions);
163163
}
164164

165-
for (final Timeline timeline : getAllTimelinesOrdered(eventType.getName())) {
165+
for (final Timeline timeline : getActiveTimelinesOrdered(eventType.getName())) {
166166
final Timeline.KafkaStoragePosition latestPosition = StaticStorageWorkerFactory.get(timeline)
167167
.getLatestPosition(timeline);
168168
if (latestPosition == null) {

0 commit comments

Comments
 (0)