masesgroup / KNet

KNet is a comprehensive .NET suite for Apache Kafka™ providing all features: Producer, Consumer, Admin, Streams, Connect, backends (ZooKeeper and Kafka).
https://knet.masesgroup.com/
Apache License 2.0
33 stars 6 forks source link

Fix condition raising System.InvalidOperationException on `KNetCompactedReplicator` #537

Closed masesdevelopers closed 2 weeks ago

masesdevelopers commented 2 weeks ago

Description

Fix condition "System.InvalidOperationException: Collection was modified; enumeration operation may not execute." can be raised if partitions are added/removed at the same time the method CheckConsumerSyncState

Related Issue

closed #536

Motivation and Context

How Has This Been Tested?

Screenshots (if appropriate):

Types of changes

Checklist: