This is an automated email from the ASF dual-hosted git repository.
pjfanning pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-connectors-kafka.git
The following commit(s) were added to refs/heads/main by this push:
new ab7079e7 Add case to handle unexpected messages in rebalance test
(#635)
ab7079e7 is described below
commit ab7079e7b858042e3f0afa243ad962da82fd3b7f
Author: PJ Fanning <[email protected]>
AuthorDate: Tue Aug 18 09:21:47 2026 +0100
Add case to handle unexpected messages in rebalance test (#635)
---
.../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]
