Package io.quarkus.kafka.client.deployment

Class DevServicesKafkaProcessor

java.lang.Object

io.quarkus.kafka.client.deployment.DevServicesKafkaProcessor

public class DevServicesKafkaProcessor
extends Object

Starts a Kafka broker as dev service if needed.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final String	DEV_SERVICE_LABEL	Label to add to shared Dev Service for Kafka running in containers.
(package private) static final int	KAFKA_PORT

Constructor Summary

Constructors

Constructor	Description
DevServicesKafkaProcessor()

Method Summary

Modifier and Type	Method	Description
void	createTopicPartitions(String bootstrapServers, KafkaDevServicesBuildTimeConfig configuration)
void	logStartedAndCreateTopicPartitions(String bootstrapServers, KafkaDevServicesBuildTimeConfig configuration)
io.quarkus.deployment.builditem.DevServicesResultBuildItem	startKafkaDevService(io.quarkus.deployment.builditem.DockerStatusBuildItem dockerStatusBuildItem, io.quarkus.deployment.builditem.DevServicesComposeProjectBuildItem compose, io.quarkus.deployment.builditem.LaunchModeBuildItem launchMode, KafkaBuildTimeConfig kafkaClientBuildTimeConfig, List<io.quarkus.deployment.builditem.DevServicesSharedNetworkBuildItem> sharedNetwork, io.quarkus.deployment.dev.devservices.DevServicesConfig devServicesConfig)

Methods inherited from class java.lang.Object

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

Field Details

DEV_SERVICE_LABEL

static final String DEV_SERVICE_LABEL

Label to add to shared Dev Service for Kafka running in containers. This allows other applications to discover the running service and use it instead of starting a new instance.

See Also:

• Constant Field Values

KAFKA_PORT

static final int KAFKA_PORT

See Also:

• Constant Field Values

Constructor Details

DevServicesKafkaProcessor

public DevServicesKafkaProcessor()

Method Details

startKafkaDevService

public io.quarkus.deployment.builditem.DevServicesResultBuildItem startKafkaDevService(io.quarkus.deployment.builditem.DockerStatusBuildItem dockerStatusBuildItem,
 io.quarkus.deployment.builditem.DevServicesComposeProjectBuildItem compose,
 io.quarkus.deployment.builditem.LaunchModeBuildItem launchMode,
 KafkaBuildTimeConfig kafkaClientBuildTimeConfig,
 List<io.quarkus.deployment.builditem.DevServicesSharedNetworkBuildItem> sharedNetwork,
 io.quarkus.deployment.dev.devservices.DevServicesConfig devServicesConfig)

logStartedAndCreateTopicPartitions

public void logStartedAndCreateTopicPartitions(String bootstrapServers,
 KafkaDevServicesBuildTimeConfig configuration)

createTopicPartitions

public void createTopicPartitions(String bootstrapServers,
 KafkaDevServicesBuildTimeConfig configuration)