package testkit
- Alphabetic
- Public
- Protected
Type Members
- 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()
- class KafkaTestkitSettings extends AnyRef
- final class KafkaTestkitTestcontainersSettings extends AnyRef
- 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()
- 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
- 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()
- object KafkaTestkitSettings
- object KafkaTestkitTestcontainersSettings
- 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()