io.micronaut.configuration.kafka.embedded

Class KafkaEmbedded

java.lang.Object

io.micronaut.configuration.kafka.embedded.KafkaEmbedded

All Implemented Interfaces:

BeanCreatedEventListener<AbstractKafkaConfiguration>, AutoCloseable, 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 Object
implements BeanCreatedEventListener<AbstractKafkaConfiguration>, 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()
Optional<kafka.server.KafkaServer>	getKafkaServer() Return the configured Kafka server is it was configured.
Optional<kafka.utils.ZkUtils>	getZkUtils() Returns the Zookeeper tools if they are available.
AbstractKafkaConfiguration	onCreated(BeanCreatedEvent<AbstractKafkaConfiguration> event) Fired when a bean is created and all PostConstruct initialization hooks have been called.

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(BeanCreatedEvent<AbstractKafkaConfiguration> event)

Description copied from interface: BeanCreatedEventListener

Fired when a bean is created and all PostConstruct initialization hooks have been called.

Specified by:

onCreated in interface BeanCreatedEventListener<AbstractKafkaConfiguration>

Parameters:

event - The bean created event

Returns:

The bean or a replacement bean of the same type

close

@PreDestroy
public void close()

Specified by:

close in interface AutoCloseable

getKafkaServer

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

Return the configured Kafka server is it was configured.

Returns:

An optional KafkaServer

getZkUtils

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

Returns the Zookeeper tools if they are available.

Returns:

The Zookeeper tools