Package io.quarkus.test.kafka

Class KafkaCompanionResource

java.lang.Object

io.quarkus.test.kafka.KafkaCompanionResource

All Implemented Interfaces:

io.quarkus.test.common.DevServicesContext.ContextAware, io.quarkus.test.common.QuarkusTestResourceLifecycleManager

Direct Known Subclasses:

ProxiedKafkaCompanionResource

public class KafkaCompanionResource
extends Object
implements io.quarkus.test.common.QuarkusTestResourceLifecycleManager, io.quarkus.test.common.DevServicesContext.ContextAware

Nested Class Summary

Nested classes/interfaces inherited from interface io.quarkus.test.common.QuarkusTestResourceLifecycleManager

io.quarkus.test.common.QuarkusTestResourceLifecycleManager.Context, io.quarkus.test.common.QuarkusTestResourceLifecycleManager.TestInjector

Field Summary

Fields

Modifier and Type	Field	Description
protected io.strimzi.test.container.StrimziKafkaContainer	kafka
static String	KAFKA_PORT_KEY
protected io.smallrye.reactive.messaging.kafka.companion.KafkaCompanion	kafkaCompanion
protected Integer	kafkaPort
protected boolean	kraft
static String	STRIMZI_KAFKA_IMAGE_KEY
protected String	strimziKafkaContainerImage

Constructor Summary

Constructors

Constructor	Description
KafkaCompanionResource()

Method Summary

Modifier and Type	Method	Description
protected io.strimzi.test.container.StrimziKafkaContainer	createContainer(String imageName)
void	init(Map<String,String> initArgs)
void	inject(io.quarkus.test.common.QuarkusTestResourceLifecycleManager.TestInjector testInjector)
void	setIntegrationTestContext(io.quarkus.test.common.DevServicesContext context)
Map<String,String>	start()
void	stop()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.quarkus.test.common.QuarkusTestResourceLifecycleManager

inject, order, setContext

Field Details

STRIMZI_KAFKA_IMAGE_KEY

public static String STRIMZI_KAFKA_IMAGE_KEY

KAFKA_PORT_KEY

public static String KAFKA_PORT_KEY

strimziKafkaContainerImage

protected String strimziKafkaContainerImage

kafkaPort

protected Integer kafkaPort

kraft

protected boolean kraft

kafka

protected io.strimzi.test.container.StrimziKafkaContainer kafka

kafkaCompanion

protected io.smallrye.reactive.messaging.kafka.companion.KafkaCompanion kafkaCompanion

Constructor Details

KafkaCompanionResource

public KafkaCompanionResource()

Method Details

setIntegrationTestContext

public void setIntegrationTestContext(io.quarkus.test.common.DevServicesContext context)

Specified by:

setIntegrationTestContext in interface io.quarkus.test.common.DevServicesContext.ContextAware

createContainer

protected io.strimzi.test.container.StrimziKafkaContainer createContainer(String imageName)

init

public void init(Map<String,String> initArgs)

Specified by:

init in interface io.quarkus.test.common.QuarkusTestResourceLifecycleManager

start

public Map<String,String> start()

Specified by:

start in interface io.quarkus.test.common.QuarkusTestResourceLifecycleManager

stop

public void stop()

Specified by:

stop in interface io.quarkus.test.common.QuarkusTestResourceLifecycleManager

inject

public void inject(io.quarkus.test.common.QuarkusTestResourceLifecycleManager.TestInjector testInjector)

Specified by:

inject in interface io.quarkus.test.common.QuarkusTestResourceLifecycleManager