@ConfigurationProperties(value="kafka") @Requires(value="kafka") public class KafkaDefaultConfiguration extends AbstractKafkaConfiguration
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_HEALTHTIMEOUT
The default health timeout value.
|
DEFAULT_BOOTSTRAP_SERVERS, DEFAULT_KAFKA_PORT, EMBEDDED, EMBEDDED_TOPICS, PREFIX
Constructor and Description |
---|
KafkaDefaultConfiguration(Environment environment)
Constructs the default Kafka configuration.
|
Modifier and Type | Method and Description |
---|---|
Duration |
getHealthTimeout()
The health check timeout.
|
void |
setHealthTimeout(Duration healthTimeout)
The health check timeout.
|
getConfig
public static final int DEFAULT_HEALTHTIMEOUT
public KafkaDefaultConfiguration(Environment environment)
environment
- The environment