Fix flaky RegexSourceIntegrationTest.testMultipleConsumersCanReadFromPartitionedTopic
similar to and
Reviewers:  Matthias J. Sax  Bill Bejeck
@@ -318,8 +318,8 @@ public class RegexSourceIntegrationTest {
partitionedStreamLeader.to(outputTopic, Produced.with(stringSerde, stringSerde));
partitionedStreamFollower.to(outputTopic, Produced.with(stringSerde, stringSerde));
- final List<String> leaderAssignment = new ArrayList<>();
- final List<String> followerAssignment = new ArrayList<>();
+ final List<String> leaderAssignment = new CopyOnWriteArrayList<>();
+ final List<String> followerAssignment = new CopyOnWriteArrayList<>();
partitionedStreamsLeader = new KafkaStreams(builderLeader.build(), streamsConfiguration, new DefaultKafkaClientSupplier() {
@Override
