KAFKA-8298: Fix possible concurrent modification exception (#6643)
When processing multiple key-changing operations during the optimization phase a ConcurrentModificationException is possible.
Reviewers: Guozhang Wang <wangguoz@gmail.com>
@ -311,8 +313,10 @@ public class InternalStreamsBuilder implements InternalNameProvider {
@@ -311,8 +313,10 @@ public class InternalStreamsBuilder implements InternalNameProvider {
@ -368,7 +372,7 @@ public class InternalStreamsBuilder implements InternalNameProvider {
@@ -368,7 +372,7 @@ public class InternalStreamsBuilder implements InternalNameProvider {