io.micronaut.configuration.kafka.config

Class KafkaDefaultConfiguration

java.lang.Object

io.micronaut.configuration.kafka.config.AbstractKafkaConfiguration

io.micronaut.configuration.kafka.config.KafkaDefaultConfiguration

@ConfigurationProperties(value="kafka")
 @Requires(value="kafka")
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 and Description
static int	DEFAULT_HEALTHTIMEOUT The default health timeout value.

Fields inherited from class io.micronaut.configuration.kafka.config.AbstractKafkaConfiguration

DEFAULT_BOOTSTRAP_SERVERS, DEFAULT_KAFKA_PORT, EMBEDDED, EMBEDDED_TOPICS, PREFIX

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class io.micronaut.configuration.kafka.config.AbstractKafkaConfiguration

getConfig

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_HEALTHTIMEOUT

public static final int DEFAULT_HEALTHTIMEOUT

The default health timeout value.

See Also:

Constant Field Values

Constructor Detail

KafkaDefaultConfiguration

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

Constructs the default Kafka configuration.

Parameters:

environment - The environment

Method Detail

getHealthTimeout

public java.time.Duration getHealthTimeout()

The health check timeout.

Returns:

The duration

setHealthTimeout

public void setHealthTimeout(java.time.Duration healthTimeout)

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

Parameters:

healthTimeout - The duration