io.micronaut.configuration.kafka.embedded

Class KafkaEmbedded

java.lang.Object

io.micronaut.configuration.kafka.embedded.KafkaEmbedded

All Implemented Interfaces:

io.micronaut.context.event.BeanCreatedEventListener<AbstractKafkaConfiguration>, java.lang.AutoCloseable, java.util.EventListener

@Singleton
 @Requires(env={"test","dev"}) @Requires(classes={kafka.server.KafkaServer.class,org.I0Itec.zkclient.ZkClient.class,kafka.utils.TestUtils.class,org.apache.kafka.test.TestUtils.class}) @Requires(property="kafka.embedded.enabled")
public class KafkaEmbedded
extends java.lang.Object
implements io.micronaut.context.event.BeanCreatedEventListener<AbstractKafkaConfiguration>, java.lang.AutoCloseable

This class will configure a Kafka server for the test environment if no server is already available.

Since:

1.0

Author:

Graeme Rocher

Constructor Summary

Constructors

Constructor and Description
KafkaEmbedded(KafkaEmbeddedConfiguration embeddedConfiguration) Construct a new instance.

Method Summary

Modifier and Type	Method and Description
void	close()
java.util.Optional<kafka.server.KafkaServer>	getKafkaServer() Return the configured Kafka server is it was configured.
java.util.Optional<java.lang.Integer>	getZkPort() Returns the port Zookeeper is running on if it was created.
java.util.Optional<kafka.utils.ZkUtils>	getZkUtils() Returns the Zookeeper tools if they are available.
AbstractKafkaConfiguration	onCreated(io.micronaut.context.event.BeanCreatedEvent<AbstractKafkaConfiguration> event)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaEmbedded

public KafkaEmbedded(KafkaEmbeddedConfiguration embeddedConfiguration)

Construct a new instance.

Parameters:

embeddedConfiguration - The KafkaEmbeddedConfiguration

Method Detail

onCreated

public AbstractKafkaConfiguration onCreated(io.micronaut.context.event.BeanCreatedEvent<AbstractKafkaConfiguration> event)

Specified by:

onCreated in interface io.micronaut.context.event.BeanCreatedEventListener<AbstractKafkaConfiguration>

close

@PreDestroy
public void close()

Specified by:

close in interface java.lang.AutoCloseable

getKafkaServer

public java.util.Optional<kafka.server.KafkaServer> getKafkaServer()

Return the configured Kafka server is it was configured.

Returns:

An optional KafkaServer

getZkUtils

public java.util.Optional<kafka.utils.ZkUtils> getZkUtils()

Returns the Zookeeper tools if they are available.

Returns:

The Zookeeper tools

getZkPort

public java.util.Optional<java.lang.Integer> getZkPort()

Returns the port Zookeeper is running on if it was created.

Returns:

The Zookeeper port