@Singleton @Requires(env={"test","dev"}) @Requires(classes={kafka.server.KafkaServer.class,kafka.utils.TestUtils.class,org.apache.kafka.test.TestUtils.class}) @Requires(property="kafka.embedded.enabled") @Deprecated public class KafkaEmbedded extends java.lang.Object implements io.micronaut.context.event.BeanCreatedEventListener<AbstractKafkaConfiguration>, java.lang.AutoCloseable
Constructor and Description |
---|
KafkaEmbedded(KafkaEmbeddedConfiguration embeddedConfiguration)
Deprecated.
Construct a new instance.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Deprecated.
|
java.util.Optional<kafka.server.KafkaServer> |
getKafkaServer()
Deprecated.
Return the configured Kafka server is it was configured.
|
java.util.Optional<java.lang.Integer> |
getZkPort()
Deprecated.
Returns the port Zookeeper is running on if it was created.
|
AbstractKafkaConfiguration |
onCreated(io.micronaut.context.event.BeanCreatedEvent<AbstractKafkaConfiguration> event)
Deprecated.
|
public KafkaEmbedded(KafkaEmbeddedConfiguration embeddedConfiguration)
embeddedConfiguration
- The KafkaEmbeddedConfiguration
public AbstractKafkaConfiguration onCreated(io.micronaut.context.event.BeanCreatedEvent<AbstractKafkaConfiguration> event)
onCreated
in interface io.micronaut.context.event.BeanCreatedEventListener<AbstractKafkaConfiguration>
@PreDestroy public void close()
close
in interface java.lang.AutoCloseable
public java.util.Optional<kafka.server.KafkaServer> getKafkaServer()
KafkaServer
public java.util.Optional<java.lang.Integer> getZkPort()