@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
Constructor and Description |
---|
KafkaEmbedded(KafkaEmbeddedConfiguration embeddedConfiguration)
Construct a new instance.
|
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. |
public KafkaEmbedded(KafkaEmbeddedConfiguration embeddedConfiguration)
embeddedConfiguration
- The KafkaEmbeddedConfiguration
public AbstractKafkaConfiguration onCreated(BeanCreatedEvent<AbstractKafkaConfiguration> event)
BeanCreatedEventListener
PostConstruct
initialization hooks have been
called.onCreated
in interface BeanCreatedEventListener<AbstractKafkaConfiguration>
event
- The bean created event@PreDestroy public void close()
close
in interface AutoCloseable
public Optional<kafka.server.KafkaServer> getKafkaServer()
KafkaServer
public Optional<kafka.utils.ZkUtils> getZkUtils()