kafka/checkstyle
Luke Chen 33c313d853 KAFKA-13081: detect and handle doubly assigned partitions in cooperative assignor (#11068)
This is the fix 1 and fix 2 in #10985 for v2.6, including the tests. Uses the generation to invalidate previous assignments that claim partitions but no longer own them, and implements an additional safety net to handle any case in which doubly-claimed partitions slip in to the input anyway

Reviewers: Anna Sophie Blee-Goldman <ableegoldman@apache.org>
2021-10-19 16:21:16 -07:00
..
.scalafmt.conf MINOR: Add Scalafmt to Streams Scala API (#4965) 2018-07-09 16:48:34 -07:00
checkstyle.xml KAFKA-7308: Fix rat and checkstyle config for Java 11 support (#5529) 2018-08-18 08:18:28 -07:00
import-control-core.xml MINOR: Update usage of deprecated API (#6146) 2019-01-29 11:15:43 -08:00
import-control-jmh-benchmarks.xml KAFKA-9039: Optimize ReplicaFetcher fetch path (#7443) 2019-10-16 09:49:53 -07:00
import-control.xml KAFKA-10049: Fixed FKJ bug where wrapped serdes are set incorrectly when using default StreamsConfig serdes (#8764) 2020-06-12 11:26:37 -05:00
java.header MINOR: improve license header check by providing head file instead of (prefix) header regex 2017-02-28 12:35:04 -08:00
suppressions.xml KAFKA-13081: detect and handle doubly assigned partitions in cooperative assignor (#11068) 2021-10-19 16:21:16 -07:00