Class TestKitNodes

java.lang.Object

org.apache.kafka.common.test.TestKitNodes

public class TestKitNodes
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestKitNodes.Builder

Method Summary

Modifier and Type	Method	Description
String	baseDirectory()
org.apache.kafka.metadata.bootstrap.BootstrapMetadata	bootstrapMetadata()
org.apache.kafka.common.network.ListenerName	brokerListenerName()
org.apache.kafka.common.security.auth.SecurityProtocol	brokerListenerProtocol()
SortedMap<Integer, TestKitNode>	brokerNodes()
String	clusterId()
org.apache.kafka.common.network.ListenerName	controllerListenerName()
org.apache.kafka.common.security.auth.SecurityProtocol	controllerListenerProtocol()
SortedMap<Integer, TestKitNode>	controllerNodes()
boolean	isCombined(int node)

Methods inherited from class java.lang.Object

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

Method Details

isCombined

public boolean isCombined(int node)

baseDirectory

public String baseDirectory()

clusterId

public String clusterId()

controllerNodes

public SortedMap<Integer, TestKitNode> controllerNodes()

bootstrapMetadata

public org.apache.kafka.metadata.bootstrap.BootstrapMetadata bootstrapMetadata()

brokerNodes

public SortedMap<Integer, TestKitNode> brokerNodes()

brokerListenerName

public org.apache.kafka.common.network.ListenerName brokerListenerName()

brokerListenerProtocol

public org.apache.kafka.common.security.auth.SecurityProtocol brokerListenerProtocol()

controllerListenerName

public org.apache.kafka.common.network.ListenerName controllerListenerName()

controllerListenerProtocol

public org.apache.kafka.common.security.auth.SecurityProtocol controllerListenerProtocol()