Packages

package testkit

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Package Members

  1. package internal
  2. package javadsl
  3. package scaladsl

Type Members

  1. abstract class KafkaTest extends BaseKafkaTest

    JUnit 5 aka Jupiter base-class with some convenience for accessing a Kafka broker.

    JUnit 5 aka Jupiter base-class with some convenience for accessing a Kafka broker. Extending classes must be annotated with @TestInstance(Lifecycle.PER_CLASS) to create a single instance of the test class with @BeforeAll and @AfterAll annotated methods called by the test framework.

    Annotations
    @SuppressWarnings()
  2. class KafkaTestkitSettings extends AnyRef
  3. final class KafkaTestkitTestcontainersSettings extends AnyRef
  4. abstract class TestcontainersKafkaJunit4Test extends KafkaJunit4Test

    JUnit 4 base class using Testcontainers to start a Kafka broker in a Docker container.

    JUnit 4 base class using Testcontainers to start a Kafka broker in a Docker container. The Kafka broker will be kept around across multiple test classes, unless stopKafka() is called.

    The Testcontainers dependency has to be added explicitly.

    Annotations
    @SuppressWarnings()
  5. abstract class TestcontainersKafkaTest extends KafkaTest

    JUnit 5 base class using Testcontainers to start a Kafka broker in a Docker container.

    JUnit 5 base class using Testcontainers to start a Kafka broker in a Docker container. The Kafka broker will be kept around across multiple test classes, unless stopKafka() is called (eg. from an @AfterAll-annotated method.

    Extending classes must be annotated with @TestInstance(Lifecycle.PER_CLASS) to create a single instance of the test class with @BeforeAll and @AfterAll annotated methods called by the test framework.

    The Testcontainers dependency has to be added explicitly.

    Annotations
    @SuppressWarnings()

Value Members

  1. object ConsumerResultFactory

    Factory methods to create instances that normally are emitted by pekko.kafka.scaladsl.Consumer and pekko.kafka.javadsl.Consumer flows.

    Factory methods to create instances that normally are emitted by pekko.kafka.scaladsl.Consumer and pekko.kafka.javadsl.Consumer flows.

    Annotations
    @ApiMayChange()
  2. object KafkaTestkitSettings
  3. object KafkaTestkitTestcontainersSettings
  4. object ProducerResultFactory

    Factory methods to create instances that normally are emitted by pekko.kafka.scaladsl.Producer and pekko.kafka.javadsl.Producer flows.

    Factory methods to create instances that normally are emitted by pekko.kafka.scaladsl.Producer and pekko.kafka.javadsl.Producer flows.

    Annotations
    @ApiMayChange()

Ungrouped