Skip to content

Commit

Permalink
GH-3186: Filter out successful commits from retry
Browse files Browse the repository at this point in the history
Closes #3186

* Don't retry failed commits due to rebalance if they are subsequently superseded by successful commits
* Modify rebalance test cases to capture the scenario that triggers the bug
  • Loading branch information
mikael-carlstedt committed Apr 11, 2024
1 parent c09054e commit 988edeb
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -164,6 +164,7 @@
* @author Wang Zhiyang
* @author Raphael Rösch
* @author Christian Mergenthaler
* @author Mikael Carlstedt
*/
public class KafkaMessageListenerContainer<K, V> // NOSONAR line count
extends AbstractMessageListenerContainer<K, V> implements ConsumerPauseResumeEventPublisher {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -143,6 +143,7 @@
* @author Daniel Gentes
* @author Soby Chacko
* @author Wang Zhiyang
* @author Mikael Carlstedt
*/
@EmbeddedKafka(topics = { KafkaMessageListenerContainerTests.topic1, KafkaMessageListenerContainerTests.topic2,
KafkaMessageListenerContainerTests.topic3, KafkaMessageListenerContainerTests.topic4,
Expand Down

0 comments on commit 988edeb

Please sign in to comment.