Package org.apache.kafka.common.test.junit

Class RaftClusterInvocationContext

java.lang.Object

org.apache.kafka.common.test.junit.RaftClusterInvocationContext

All Implemented Interfaces:

org.junit.jupiter.api.extension.TestTemplateInvocationContext

public class RaftClusterInvocationContext
extends Object
implements org.junit.jupiter.api.extension.TestTemplateInvocationContext

Wraps a KafkaClusterTestKit inside lifecycle methods for a test invocation. Each instance of this class is provided with a configuration for the cluster. This context also provides parameter resolvers for:

• ClusterConfig (the same instance passed to the constructor)
• ClusterInstance (includes methods to expose underlying SocketServer-s)

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RaftClusterInvocationContext.RaftClusterInstance

Constructor Summary

Constructors

Constructor	Description
RaftClusterInvocationContext(String baseDisplayName, org.apache.kafka.common.test.api.ClusterConfig clusterConfig, boolean isCombined)

Method Summary

Modifier and Type	Method	Description
List<org.junit.jupiter.api.extension.Extension>	getAdditionalExtensions()
String	getDisplayName(int invocationIndex)

Methods inherited from class java.lang.Object

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

Constructor Details

RaftClusterInvocationContext

public RaftClusterInvocationContext(String baseDisplayName,
 org.apache.kafka.common.test.api.ClusterConfig clusterConfig,
 boolean isCombined)

Method Details

getDisplayName

public String getDisplayName(int invocationIndex)

Specified by:

getDisplayName in interface org.junit.jupiter.api.extension.TestTemplateInvocationContext

getAdditionalExtensions

public List<org.junit.jupiter.api.extension.Extension> getAdditionalExtensions()

Specified by:

getAdditionalExtensions in interface org.junit.jupiter.api.extension.TestTemplateInvocationContext