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

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.clients.admin.Admin	admin()
org.apache.kafka.clients.admin.Admin	admin(Map<String,Object> configs)
org.apache.kafka.clients.admin.Admin	admin(Map<String,Object> configs, boolean usingBootstrapControllers)
String	bootstrapControllers()
String	bootstrapServers()
Map<Integer, kafka.server.BrokerServer>	brokers()
void	close()
String	clusterId()
Map<Integer, kafka.server.ControllerServer>	controllers()
MockFaultHandler	fatalFaultHandler()
void	format()
scala.Option<CompletableFuture<Integer>>	interBrokerPortFuture()
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 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

admin

public org.apache.kafka.clients.admin.Admin admin()

admin

public org.apache.kafka.clients.admin.Admin admin(Map<String,Object> configs)

admin

public org.apache.kafka.clients.admin.Admin admin(Map<String,Object> configs,
 boolean usingBootstrapControllers)

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()