This is an automated email from the ASF dual-hosted git repository. pjfanning pushed a commit to branch pjfanning-patch-3 in repository https://gitbox.apache.org/repos/asf/pekko-connectors-kafka.git
commit 31331fb4321076599f6dde9d56289b51e6f9a5a5 Author: PJ Fanning <[email protected]> AuthorDate: Mon Aug 17 10:52:33 2026 +0100 Add case to handle unexpected messages in rebalance test --- .../scala/org/apache/pekko/kafka/scaladsl/CooperativeRebalanceSpec.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/tests/src/test/scala/org/apache/pekko/kafka/scaladsl/CooperativeRebalanceSpec.scala b/tests/src/test/scala/org/apache/pekko/kafka/scaladsl/CooperativeRebalanceSpec.scala index 482e5122..d2a8995f 100644 --- a/tests/src/test/scala/org/apache/pekko/kafka/scaladsl/CooperativeRebalanceSpec.scala +++ b/tests/src/test/scala/org/apache/pekko/kafka/scaladsl/CooperativeRebalanceSpec.scala @@ -76,6 +76,7 @@ class CooperativeRebalanceSpec extends SpecBase with TestcontainersKafkaLike wit rebalanceActor.fishForMessage(10.seconds) { case TopicPartitionsAssigned(`subscription`, assigned) if assigned == tps => true case TopicPartitionsAssigned(`subscription`, assigned) if assigned.isEmpty => false + case _ => false } sealed trait SourceCase { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
