@ConfigurationProperties(value="kafka.embedded") public class KafkaEmbeddedConfiguration extends Object implements Toggleable
Modifier and Type | Field and Description |
---|---|
static boolean |
DEFAULT_ENABLED
The default enable value.
|
static String |
PREFIX
The prefix used for configuration.
|
Constructor and Description |
---|
KafkaEmbeddedConfiguration() |
Modifier and Type | Method and Description |
---|---|
Properties |
getProperties() |
List<String> |
getTopics() |
boolean |
isEnabled() |
void |
setEnabled(boolean enabled)
Sets whether the embedded Kafka server is enabled.
|
void |
setProperties(Properties properties)
Sets the broker properties.
|
void |
setTopics(List<String> topics)
The topics that should be created by the embedded instance.
|
public static final String PREFIX
public static final boolean DEFAULT_ENABLED
public boolean isEnabled()
isEnabled
in interface Toggleable
public void setEnabled(boolean enabled)
enabled
- True if it is.@Nonnull public Properties getProperties()
public void setProperties(Properties properties)
properties
- The broker properties.public List<String> getTopics()