Skip to content

Commit 94f5aad

Browse files
chia7712bbejeck
authored andcommitted
KAFKA-8861 Fix flaky RegexSourceIntegrationTest.testMultipleConsumersCanReadFromPartitionedTopic (apache#7281)
similar to https://issues.apache.org/jira/browse/KAFKA-8011 and https://issues.apache.org/jira/browse/KAFKA-8026 Reviewers: Matthias J. Sax <[email protected]>, Bill Bejeck <[email protected]>
1 parent 8cdc2d6 commit 94f5aad

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

streams/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -337,8 +337,8 @@ public void testMultipleConsumersCanReadFromPartitionedTopic() throws Exception
337337
partitionedStreamLeader.to(DEFAULT_OUTPUT_TOPIC, Produced.with(stringSerde, stringSerde));
338338
partitionedStreamFollower.to(DEFAULT_OUTPUT_TOPIC, Produced.with(stringSerde, stringSerde));
339339

340-
final List<String> leaderAssignment = new ArrayList<>();
341-
final List<String> followerAssignment = new ArrayList<>();
340+
final List<String> leaderAssignment = new CopyOnWriteArrayList<>();
341+
final List<String> followerAssignment = new CopyOnWriteArrayList<>();
342342

343343
partitionedStreamsLeader = new KafkaStreams(builderLeader.build(), streamsConfiguration, new DefaultKafkaClientSupplier() {
344344
@Override

0 commit comments

Comments
 (0)