package scaladsl
- Alphabetic
- Public
- Protected
Type Members
- abstract class KafkaSpec extends TestKit with KafkaTestKit
- abstract class ScalatestKafkaSpec extends KafkaSpec with Suite with Scalatest
- trait TestcontainersKafkaLike extends KafkaSpec with Spec
Uses Testcontainers to start a Kafka cluster in a Docker container.
Uses Testcontainers to start a Kafka cluster in a Docker container. This trait will start Kafka only once per test session. To create a Kafka cluster per test class see TestcontainersKafkaPerClassLike.
The Testcontainers dependency has to be added explicitly.
- trait TestcontainersKafkaPerClassLike extends KafkaSpec with Spec
Uses Testcontainers to start a Kafka broker in a Docker container once per class.
Uses Testcontainers to start a Kafka broker in a Docker container once per class. The Testcontainers dependency has to be added explicitly.
Value Members
- object ConsumerControlFactory
Helper factory to create pekko.kafka.scaladsl.Consumer.Control instances when testing without a Kafka broker.
Helper factory to create pekko.kafka.scaladsl.Consumer.Control instances when testing without a Kafka broker.
- Annotations
- @ApiMayChange()