Class KafkaDefaultConfiguration

java.lang.Object

io.micronaut.configuration.kafka.config.AbstractKafkaConfiguration

io.micronaut.configuration.kafka.config.KafkaDefaultConfiguration

All Implemented Interfaces:

io.micronaut.core.util.Toggleable

@ConfigurationProperties("kafka")
@Requires(property="kafka") @Requires(property="kafka.enabled",notEquals="false")
public class KafkaDefaultConfiguration
extends AbstractKafkaConfiguration

The default Kafka configuration to apply to both the consumer and the producer, but can be overridden by either.

Since:

1.0

Author:

Graeme Rocher

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_HEALTHTIMEOUT	The default health timeout value.

Fields inherited from class AbstractKafkaConfiguration

DEFAULT_BOOTSTRAP_SERVERS, DEFAULT_KAFKA_PORT, EMBEDDED_TOPICS, PREFIX, TOPICS

Constructor Summary

Constructors

Constructor	Description
KafkaDefaultConfiguration(io.micronaut.context.env.Environment environment)	Constructs the default Kafka configuration.

Method Summary

Modifier and Type	Method	Description
Duration	getHealthTimeout()	The health check timeout.
void	setHealthTimeout(Duration healthTimeout)	The health check timeout.

Methods inherited from class AbstractKafkaConfiguration

getConfig, toKafkaProperties

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.micronaut.core.util.Toggleable

isEnabled

Field Details

DEFAULT_HEALTHTIMEOUT

public static final int DEFAULT_HEALTHTIMEOUT

The default health timeout value.

See Also:

• Constant Field Values

Constructor Details

KafkaDefaultConfiguration

public KafkaDefaultConfiguration(io.micronaut.context.env.Environment environment)

Constructs the default Kafka configuration.

Parameters:

environment - The environment

Method Details

getHealthTimeout

public Duration getHealthTimeout()

The health check timeout.

Returns:

The duration

setHealthTimeout

public void setHealthTimeout(Duration healthTimeout)

The health check timeout. Default value (10 seconds).

Parameters:

healthTimeout - The duration