Package io.quarkus.test.kafka

Class ProxiedKafkaCompanionResource

java.lang.Object

io.quarkus.test.kafka.KafkaCompanionResource

io.quarkus.test.kafka.ProxiedKafkaCompanionResource

All Implemented Interfaces:

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

public class ProxiedKafkaCompanionResource
extends KafkaCompanionResource

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 inherited from class io.quarkus.test.kafka.KafkaCompanionResource

kafka, KAFKA_PORT_KEY, kafkaCompanion, kafkaPort, kraft, STRIMZI_KAFKA_IMAGE_KEY, strimziKafkaContainerImage

Constructor Summary

Constructors

Constructor	Description
ProxiedKafkaCompanionResource()

Method Summary

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

Methods inherited from class io.quarkus.test.kafka.KafkaCompanionResource

init, setIntegrationTestContext, 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

Constructor Details

ProxiedKafkaCompanionResource

public ProxiedKafkaCompanionResource()

Method Details

createContainer

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

Overrides:

createContainer in class KafkaCompanionResource

start

public Map<String,String> start()

Specified by:

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

Overrides:

start in class KafkaCompanionResource

inject

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

Specified by:

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

Overrides:

inject in class KafkaCompanionResource