Packages

package scaladsl

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. abstract class KafkaSpec extends TestKit with KafkaTestKit
  2. abstract class ScalatestKafkaSpec extends KafkaSpec with Suite with Scalatest
  3. 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.

  4. 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

  1. 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()

Ungrouped