Type Members

1.  class KafkaContainerCluster extends Startable

   Provides an easy way to launch a Kafka cluster with multiple brokers.

   Provides an easy way to launch a Kafka cluster with multiple brokers.

   Annotations

   @InternalApi()

2.  trait KafkaTestKit extends AnyRef

   Common functions for scaladsl and javadsl Testkit.

   Common functions for scaladsl and javadsl Testkit.

   Mixed-in in both, scaladsl and javadsl classes, therefore API should be usable from both - Scala and Java.

3.  abstract class KafkaTestKitClass extends KafkaTestKit
4.  class PekkoConnectorsKafkaContainer extends GenericContainer[PekkoConnectorsKafkaContainer]

   This container wraps Confluent Kafka and Zookeeper (optionally)

   This container wraps Confluent Kafka and Zookeeper (optionally)

   This is a copy of KafkaContainer from testcontainers/testcontainers-java that we can tweak as needed

   Annotations

   @InternalApi()

5.  class SchemaRegistryContainer extends GenericContainer[SchemaRegistryContainer]
6.  trait TestFrameworkInterface extends AnyRef