This is an automated email from the ASF dual-hosted git repository. engelen pushed a commit to branch update/kafka-clients-4.0.0 in repository https://gitbox.apache.org/repos/asf/pekko-connectors-kafka.git
commit c6d7ec3bc097ec1ebcd3cb8b5fe7cadc2883ed1f Author: PJ Fanning <[email protected]> AuthorDate: Wed Mar 26 13:18:21 2025 +0100 Update KafkaSpec.scala --- .../main/scala/org/apache/pekko/kafka/testkit/scaladsl/KafkaSpec.scala | 2 ++ 1 file changed, 2 insertions(+) diff --git a/testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl/KafkaSpec.scala b/testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl/KafkaSpec.scala index 4519a193..59851477 100644 --- a/testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl/KafkaSpec.scala +++ b/testkit/src/main/scala/org/apache/pekko/kafka/testkit/scaladsl/KafkaSpec.scala @@ -37,6 +37,7 @@ import org.apache.kafka.clients.producer.{ Producer => KProducer, ProducerRecord import org.apache.kafka.common.ConsumerGroupState import org.slf4j.{ Logger, LoggerFactory } +import scala.annotation.nowarn import scala.collection.immutable import scala.concurrent.duration._ import scala.concurrent.{ Await, ExecutionContext, Future } @@ -119,6 +120,7 @@ abstract class KafkaSpec(_kafkaPort: Int, val zooKeeperPort: Int, actorSystem: A * * If the predicate does not hold after configured amount of time, throws an exception. */ + @nowarn("cat=deprecation") def waitUntilConsumerSummary(groupId: String)(predicate: PartialFunction[List[MemberDescription], Boolean]): Unit = waitUntilConsumerGroup(groupId) { group => group.state() == ConsumerGroupState.STABLE && --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
