Packages

package javadsl

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Type Members

  1. abstract class BaseKafkaTest extends KafkaTestKitClass
  2. abstract class KafkaJunit4Test extends BaseKafkaTest

    JUnit 4 base-class with some convenience for accessing a Kafka broker.

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

  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.

  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.

Value Members

  1. object ConsumerControlFactory

    Helper factory to create akka.kafka.javadsl.Consumer.Control instances when testing without a Kafka broker.

    Helper factory to create akka.kafka.javadsl.Consumer.Control instances when testing without a Kafka broker.

    Annotations
    @ApiMayChange()

Ungrouped