class KafkaContainerCluster extends Startable
Provides an easy way to launch a Kafka cluster with multiple brokers.
- Annotations
- @InternalApi()
- Source
- KafkaContainerCluster.java
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- KafkaContainerCluster
- Startable
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new KafkaContainerCluster(zooKeeperImage: DockerImageName, kafkaImage: DockerImageName, schemaRegistryImage: DockerImageName, brokersNum: Int, internalTopicsRf: Int, useSchemaRegistry: Boolean, containerLogging: Boolean, clusterStartTimeout: Duration, readinessCheckTimeout: Duration)
- new KafkaContainerCluster(brokersNum: Int, internalTopicsRf: Int)
Value Members
- def close(): Unit
- Definition Classes
- Startable → AutoCloseable
- def getBootstrapServers(): String
- def getBrokers(): Collection[PekkoConnectorsKafkaContainer]
- def getDependencies(): Set[Startable]
- Definition Classes
- Startable
- def getInternalNetworkBootstrapServers(): String
- def getNetwork(): Network
- def getSchemaRegistry(): Optional[SchemaRegistryContainer]
- def getZooKeeper(): GenericContainer[SELF] forSome {type SELF <: GenericContainer[SELF]}
- def start(): Unit
- Definition Classes
- KafkaContainerCluster → Startable
- Annotations
- @Override()
- def startKafka(): Unit
- def stop(): Unit
- Definition Classes
- KafkaContainerCluster → Startable
- Annotations
- @Override()
- def stopKafka(): Unit