Package org.apache.kafka.common.test

Class KafkaClusterTestKit

java.lang.Object

org.apache.kafka.common.test.KafkaClusterTestKit

All Implemented Interfaces:

AutoCloseable

public class KafkaClusterTestKit
extends Object
implements AutoCloseable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	KafkaClusterTestKit.Builder
class	KafkaClusterTestKit.ClientPropertiesBuilder

Method Summary

Modifier and Type	Method	Description
String	bootstrapControllers()
String	bootstrapServers()
Map<Integer,kafka.server.BrokerServer>	brokers()
Properties	clientProperties()
void	close()
String	clusterId()
Map<Integer,kafka.server.ControllerServer>	controllers()
MockFaultHandler	fatalFaultHandler()
void	format()
scala.Option<CompletableFuture<Integer>>	interBrokerPortFuture()
KafkaClusterTestKit.ClientPropertiesBuilder	newClientPropertiesBuilder()
KafkaClusterTestKit.ClientPropertiesBuilder	newClientPropertiesBuilder(Properties properties)
TestKitNodes	nodes()
MockFaultHandler	nonFatalFaultHandler()
Map<Integer,kafka.raft.KafkaRaftManager<org.apache.kafka.server.common.ApiMessageAndVersion>>	raftManagers()
void	shutdownAll()
void	startup()
org.apache.kafka.controller.Controller	waitForActiveController()
void	waitForReadyBrokers()	Wait for a controller to mark all the brokers as ready (registered and unfenced).

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

format

public void format()
            throws Exception

Throws:

Exception

startup

public void startup()
             throws ExecutionException,
InterruptedException

Throws:

ExecutionException

InterruptedException

waitForReadyBrokers

public void waitForReadyBrokers()
                         throws ExecutionException,
InterruptedException

Wait for a controller to mark all the brokers as ready (registered and unfenced). And also wait for the metadata cache up-to-date in each broker server.

Throws:

ExecutionException

InterruptedException

newClientPropertiesBuilder

public KafkaClusterTestKit.ClientPropertiesBuilder newClientPropertiesBuilder(Properties properties)

newClientPropertiesBuilder

public KafkaClusterTestKit.ClientPropertiesBuilder newClientPropertiesBuilder()

clientProperties

public Properties clientProperties()

bootstrapServers

public String bootstrapServers()

bootstrapControllers

public String bootstrapControllers()

controllers

public Map<Integer,kafka.server.ControllerServer> controllers()

interBrokerPortFuture

public scala.Option<CompletableFuture<Integer>> interBrokerPortFuture()

waitForActiveController

public org.apache.kafka.controller.Controller waitForActiveController()
                                                               throws InterruptedException

Throws:

InterruptedException

brokers

public Map<Integer,kafka.server.BrokerServer> brokers()

raftManagers

public Map<Integer,kafka.raft.KafkaRaftManager<org.apache.kafka.server.common.ApiMessageAndVersion>> raftManagers()

nodes

public TestKitNodes nodes()

fatalFaultHandler

public MockFaultHandler fatalFaultHandler()

nonFatalFaultHandler

public MockFaultHandler nonFatalFaultHandler()

shutdownAll

public void shutdownAll()
                 throws Exception

Throws:

Exception

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception

clusterId

public String clusterId()