Skip navigation links
A B C D E F G H I J K N O P R S T V 

A

AbstractKafkaConfiguration<K,V> - Class in io.micronaut.configuration.kafka.config
An abstract Kafka configuration class.
AbstractKafkaConfiguration(Properties) - Constructor for class io.micronaut.configuration.kafka.config.AbstractKafkaConfiguration
Constructs a new instance.
AbstractKafkaConsumerConfiguration<K,V> - Class in io.micronaut.configuration.kafka.config
Abstract Configuration for Apache Kafka Consumer.
AbstractKafkaConsumerConfiguration(Properties) - Constructor for class io.micronaut.configuration.kafka.config.AbstractKafkaConsumerConfiguration
Constructs a new instance.
AbstractKafkaProducerConfiguration<K,V> - Class in io.micronaut.configuration.kafka.config
Abstract Configuration for Apache Kafka Producer.
AbstractKafkaProducerConfiguration(Properties) - Constructor for class io.micronaut.configuration.kafka.config.AbstractKafkaProducerConfiguration
Constructs a new instance.
AbstractKafkaStreamsConfiguration<K,V> - Class in io.micronaut.configuration.kafka.streams
Abstract streams configuration.
AbstractKafkaStreamsConfiguration(KafkaDefaultConfiguration) - Constructor for class io.micronaut.configuration.kafka.streams.AbstractKafkaStreamsConfiguration
Construct a new KafkaStreamsConfiguration for the given defaults.
ack() - Method in interface io.micronaut.configuration.kafka.Acknowledgement
Deprecated.
Acknowledge the last ConsumerRecord synchronously.
Acknowledge() - Constructor for class io.micronaut.configuration.kafka.annotation.KafkaClient.Acknowledge
 
Acknowledgement - Interface in io.micronaut.configuration.kafka
Deprecated.
Use Acknowledgement instead
add(CharSequence, CharSequence) - Method in class io.micronaut.configuration.kafka.KafkaHeaders
 
AdminClientFactory - Class in io.micronaut.configuration.kafka.admin
Creates the Kakfa AdminClient.
AdminClientFactory() - Constructor for class io.micronaut.configuration.kafka.admin.AdminClientFactory
 
ALL - Static variable in class io.micronaut.configuration.kafka.annotation.KafkaClient.Acknowledge
Wait for a full set of in-sync replicas to acknowledge.
AnnotatedConsumerRecordBinder<A extends java.lang.annotation.Annotation,T> - Interface in io.micronaut.configuration.kafka.bind
Interface for binders that bind method arguments from a ConsumerRecord via a annotation.
annotationType() - Method in interface io.micronaut.configuration.kafka.bind.AnnotatedConsumerRecordBinder
 
annotationType() - Method in class io.micronaut.configuration.kafka.bind.KafkaBodyBinder
 
annotationType() - Method in class io.micronaut.configuration.kafka.bind.KafkaHeaderBinder
 
annotationType() - Method in class io.micronaut.configuration.kafka.bind.KafkaKeyBinder
 
annotationType() - Method in class io.micronaut.configuration.kafka.bind.KafkaMessagingBodyBinder
 
annotationType() - Method in class io.micronaut.configuration.kafka.scope.KafkaClientScope
 
argumentType() - Method in class io.micronaut.configuration.kafka.bind.KafkaHeadersBinder
 

B

BatchConsumerRecordsBinderRegistry - Class in io.micronaut.configuration.kafka.bind.batch
Binds arguments in batches from a ConsumerRecords instance.
BatchConsumerRecordsBinderRegistry(ConsumerRecordBinderRegistry) - Constructor for class io.micronaut.configuration.kafka.bind.batch.BatchConsumerRecordsBinderRegistry
Constructs a new instance.
bind(ArgumentConversionContext<T>, ConsumerRecord<?, ?>) - Method in class io.micronaut.configuration.kafka.bind.KafkaBodyBinder
 
bind(ArgumentConversionContext<T>, ConsumerRecord<?, ?>) - Method in class io.micronaut.configuration.kafka.bind.KafkaDefaultBinder
 
bind(ArgumentConversionContext<T>, ConsumerRecord<?, ?>) - Method in class io.micronaut.configuration.kafka.bind.KafkaHeaderBinder
 
bind(ArgumentConversionContext<MessageHeaders>, ConsumerRecord<?, ?>) - Method in class io.micronaut.configuration.kafka.bind.KafkaHeadersBinder
 
bind(ArgumentConversionContext<T>, ConsumerRecord<?, ?>) - Method in class io.micronaut.configuration.kafka.bind.KafkaKeyBinder
 
bind(ArgumentConversionContext<T>, ConsumerRecord<?, ?>) - Method in class io.micronaut.configuration.kafka.bind.KafkaMessagingBodyBinder
 

C

clone() - Method in class io.micronaut.configuration.kafka.metrics.ConsumerKafkaMetricsReporter
 
close() - Method in class io.micronaut.configuration.kafka.embedded.KafkaEmbedded
 
close() - Method in class io.micronaut.configuration.kafka.intercept.KafkaClientIntroductionAdvice
 
close() - Method in class io.micronaut.configuration.kafka.metrics.ConsumerKafkaMetricsReporter
Method to close bean.
close() - Method in class io.micronaut.configuration.kafka.metrics.ProducerKafkaMetricsReporter
Method to close bean.
close() - Method in class io.micronaut.configuration.kafka.processor.KafkaConsumerProcessor
 
close() - Method in class io.micronaut.configuration.kafka.serde.JsonSerde
 
close() - Method in class io.micronaut.configuration.kafka.streams.KafkaStreamsFactory
 
CompositeSerdeRegistry - Class in io.micronaut.configuration.kafka.serde
The default SerdeRegistry that combines multiple registries into a single registry.
CompositeSerdeRegistry(SerdeRegistry...) - Constructor for class io.micronaut.configuration.kafka.serde.CompositeSerdeRegistry
The default constructor.
configure(Map<String, ?>, boolean) - Method in class io.micronaut.configuration.kafka.serde.JsonSerde
 
ConfiguredStreamBuilder - Class in io.micronaut.configuration.kafka.streams
Extended version of StreamsBuilder that can be configured.
ConfiguredStreamBuilder(Properties) - Constructor for class io.micronaut.configuration.kafka.streams.ConfiguredStreamBuilder
Default constructor.
ConsumerAware<K,V> - Interface in io.micronaut.configuration.kafka
Interface for KafkaListener instances to implement if they wish to obtain a reference to the underlying Consumer.
ConsumerExecutorServiceConfig - Class in io.micronaut.configuration.kafka.executor
Configures a ScheduledExecutorService for running KafkaListener instances.
ConsumerExecutorServiceConfig() - Constructor for class io.micronaut.configuration.kafka.executor.ConsumerExecutorServiceConfig
 
ConsumerKafkaMetricsReporter - Class in io.micronaut.configuration.kafka.metrics
A MetricsReporter class for consumer metrics.
ConsumerKafkaMetricsReporter() - Constructor for class io.micronaut.configuration.kafka.metrics.ConsumerKafkaMetricsReporter
 
ConsumerRecordBinder<T> - Interface in io.micronaut.configuration.kafka.bind
Interface for binders that bind method arguments from a ConsumerRecord.
ConsumerRecordBinderRegistry - Class in io.micronaut.configuration.kafka.bind
A registry of ConsumerRecordBinder.
ConsumerRecordBinderRegistry(ConsumerRecordBinder<?>...) - Constructor for class io.micronaut.configuration.kafka.bind.ConsumerRecordBinderRegistry
Creates the registry for the given binders.
ConsumerRegistry - Interface in io.micronaut.configuration.kafka
A registry for created Kafka consumers.
convert(Header, Class<Object>, ConversionContext) - Method in class io.micronaut.configuration.kafka.convert.KafkaHeaderConverter
 
createConsumer(AbstractKafkaConsumerConfiguration<K, V>) - Method in class io.micronaut.configuration.kafka.KafkaConsumerFactory
Creates a new KafkaConsumer for the given configuration.
createProducer(AbstractKafkaProducerConfiguration<K, V>) - Method in class io.micronaut.configuration.kafka.KafkaProducerFactory
Creates a new KafkaProducer for the given configuration.

D

DEFAULT - Static variable in class io.micronaut.configuration.kafka.annotation.KafkaClient.Acknowledge
Relay on the default behaviour.
DEFAULT_BOOTSTRAP_SERVERS - Static variable in class io.micronaut.configuration.kafka.config.AbstractKafkaConfiguration
The default bootstrap server address.
DEFAULT_ENABLED - Static variable in class io.micronaut.configuration.kafka.embedded.KafkaEmbeddedConfiguration
The default enable value.
DEFAULT_HEALTHTIMEOUT - Static variable in class io.micronaut.configuration.kafka.config.KafkaDefaultConfiguration
The default health timeout value.
DEFAULT_KAFKA_PORT - Static variable in class io.micronaut.configuration.kafka.config.AbstractKafkaConfiguration
The default kafka port.
DefaultKafkaConsumerConfiguration<K,V> - Class in io.micronaut.configuration.kafka.config
Default Kafka consumer configuration that comes into play if no other config is specified.
DefaultKafkaConsumerConfiguration(KafkaDefaultConfiguration) - Constructor for class io.micronaut.configuration.kafka.config.DefaultKafkaConsumerConfiguration
Construct a new KafkaConsumerConfiguration for the given defaults.
DefaultKafkaConsumerConfiguration(AbstractKafkaConfiguration) - Constructor for class io.micronaut.configuration.kafka.config.DefaultKafkaConsumerConfiguration
Construct a new KafkaConsumerConfiguration for the given defaults.
DefaultKafkaListenerExceptionHandler - Class in io.micronaut.configuration.kafka.exceptions
The default ExceptionHandler used when a KafkaConsumer fails to process a ConsumerRecord.
DefaultKafkaListenerExceptionHandler() - Constructor for class io.micronaut.configuration.kafka.exceptions.DefaultKafkaListenerExceptionHandler
 
DefaultKafkaProducerConfiguration<K,V> - Class in io.micronaut.configuration.kafka.config
The default KafkaProducer configuration when no default is specified.
DefaultKafkaProducerConfiguration(KafkaDefaultConfiguration) - Constructor for class io.micronaut.configuration.kafka.config.DefaultKafkaProducerConfiguration
Constructs a new instance.
DefaultKafkaProducerConfiguration(AbstractKafkaConfiguration) - Constructor for class io.micronaut.configuration.kafka.config.DefaultKafkaProducerConfiguration
Construct a new KafkaConsumerConfiguration for the given defaults.
DefaultKafkaStreamsConfiguration<K,V> - Class in io.micronaut.configuration.kafka.streams
The default streams configuration is non other is present.
DefaultKafkaStreamsConfiguration(KafkaDefaultConfiguration, ApplicationConfiguration, Environment) - Constructor for class io.micronaut.configuration.kafka.streams.DefaultKafkaStreamsConfiguration
Construct a new KafkaStreamsConfiguration for the given defaults.
deserialize(String, byte[]) - Method in class io.micronaut.configuration.kafka.serde.JsonSerde
 
deserializer() - Method in class io.micronaut.configuration.kafka.serde.JsonSerde
 

E

EMBEDDED - Static variable in class io.micronaut.configuration.kafka.config.AbstractKafkaConfiguration
The property to use to enable embedded Kafka.
EMBEDDED_TOPICS - Static variable in class io.micronaut.configuration.kafka.config.AbstractKafkaConfiguration
The topics that should be created.

F

findArgumentBinder(Argument<T>, ConsumerRecords<?, ?>) - Method in class io.micronaut.configuration.kafka.bind.batch.BatchConsumerRecordsBinderRegistry
 
findArgumentBinder(Argument<T>, ConsumerRecord<?, ?>) - Method in class io.micronaut.configuration.kafka.bind.ConsumerRecordBinderRegistry
 

G

get(CharSequence) - Method in class io.micronaut.configuration.kafka.KafkaHeaders
 
get(CharSequence, ArgumentConversionContext<T>) - Method in class io.micronaut.configuration.kafka.KafkaHeaders
 
get(BeanResolutionContext, BeanDefinition<T>, BeanIdentifier, Provider<T>) - Method in class io.micronaut.configuration.kafka.scope.KafkaClientScope
 
getAll(CharSequence) - Method in class io.micronaut.configuration.kafka.KafkaHeaders
 
getConfig() - Method in class io.micronaut.configuration.kafka.config.AbstractKafkaConfiguration
 
getConfiguration() - Method in class io.micronaut.configuration.kafka.streams.ConfiguredStreamBuilder
The configuration.
getConsumer(String) - Method in interface io.micronaut.configuration.kafka.ConsumerRegistry
Returns a managed Consumer.
getConsumer(String) - Method in class io.micronaut.configuration.kafka.processor.KafkaConsumerProcessor
 
getConsumerIds() - Method in interface io.micronaut.configuration.kafka.ConsumerRegistry
The IDs of the available consumers.
getConsumerIds() - Method in class io.micronaut.configuration.kafka.processor.KafkaConsumerProcessor
 
getConsumerRecord() - Method in exception io.micronaut.configuration.kafka.exceptions.KafkaListenerException
 
getDeserializer(Class<T>) - Method in interface io.micronaut.configuration.kafka.serde.SerdeRegistry
Obtain a Deserializer for the given type.
getHealthTimeout() - Method in class io.micronaut.configuration.kafka.config.KafkaDefaultConfiguration
The health check timeout.
getKafkaConsumer() - Method in exception io.micronaut.configuration.kafka.exceptions.KafkaListenerException
 
getKafkaListener() - Method in exception io.micronaut.configuration.kafka.exceptions.KafkaListenerException
 
getKafkaServer() - Method in class io.micronaut.configuration.kafka.embedded.KafkaEmbedded
Return the configured Kafka server is it was configured.
getKeyDeserializer() - Method in class io.micronaut.configuration.kafka.config.AbstractKafkaConsumerConfiguration
 
getKeySerializer() - Method in class io.micronaut.configuration.kafka.config.AbstractKafkaProducerConfiguration
 
getMetricPrefix() - Method in class io.micronaut.configuration.kafka.metrics.ConsumerKafkaMetricsReporter
Abstract method to implement with the metric prefix for the reporter.
getMetricPrefix() - Method in class io.micronaut.configuration.kafka.metrics.ProducerKafkaMetricsReporter
Abstract method to implement with the metric prefix for the reporter.
getProducer(String, Argument<K>, Argument<V>) - Method in interface io.micronaut.configuration.kafka.KafkaProducerRegistry
Deprecated.
Returns a managed Producer.
getProducer(String, Argument<K>, Argument<V>) - Method in interface io.micronaut.configuration.kafka.ProducerRegistry
Returns a managed Producer.
getProducer(String, Argument<K>, Argument<V>) - Method in class io.micronaut.configuration.kafka.scope.KafkaClientScope
 
getProperties() - Method in class io.micronaut.configuration.kafka.embedded.KafkaEmbeddedConfiguration
 
getResult() - Method in class io.micronaut.configuration.kafka.health.KafkaHealthIndicator
 
getSerde(Class<T>) - Method in class io.micronaut.configuration.kafka.serde.CompositeSerdeRegistry
 
getSerde(Class<T>) - Method in class io.micronaut.configuration.kafka.serde.JsonSerdeRegistry
 
getSerde(Class<T>) - Method in interface io.micronaut.configuration.kafka.serde.SerdeRegistry
Obtain a Serde for the given type.
getSerializer(Class<T>) - Method in interface io.micronaut.configuration.kafka.serde.SerdeRegistry
Obtain a Serializer for the given type.
getTopics() - Method in class io.micronaut.configuration.kafka.embedded.KafkaEmbeddedConfiguration
 
getValueDeserializer() - Method in class io.micronaut.configuration.kafka.config.AbstractKafkaConsumerConfiguration
 
getValueSerializer() - Method in class io.micronaut.configuration.kafka.config.AbstractKafkaProducerConfiguration
 
getZkPort() - Method in class io.micronaut.configuration.kafka.embedded.KafkaEmbedded
Returns the port Zookeeper is running on if it was created.
getZkUtils() - Method in class io.micronaut.configuration.kafka.embedded.KafkaEmbedded
Returns the Zookeeper tools if they are available.

H

handle(KafkaListenerException) - Method in class io.micronaut.configuration.kafka.exceptions.DefaultKafkaListenerExceptionHandler
 

I

init(ApplicationConfiguration, Environment, Properties) - Method in class io.micronaut.configuration.kafka.streams.AbstractKafkaStreamsConfiguration
Shared initialization.
intercept(MethodInvocationContext<Object, Object>) - Method in class io.micronaut.configuration.kafka.intercept.KafkaClientIntroductionAdvice
 
io.micronaut.configuration.kafka - package io.micronaut.configuration.kafka
Contains classes, interfaces and annotations that provide integration with Apache Kafka.
io.micronaut.configuration.kafka.admin - package io.micronaut.configuration.kafka.admin
Classes related to administration of Kafka.
io.micronaut.configuration.kafka.annotation - package io.micronaut.configuration.kafka.annotation
Annotations for creating Kafka consumers and producers.
io.micronaut.configuration.kafka.bind - package io.micronaut.configuration.kafka.bind
Classes related to binding Kafka ConsumerRecord instances to method signatures.
io.micronaut.configuration.kafka.bind.batch - package io.micronaut.configuration.kafka.bind.batch
Classes related to binding Kafka ConsumerRecords instances to method signatures in batch.
io.micronaut.configuration.kafka.config - package io.micronaut.configuration.kafka.config
Configurations classes for configuring Kafka Consumer and Producer instances.
io.micronaut.configuration.kafka.convert - package io.micronaut.configuration.kafka.convert
Additional TypeConverter instances specific to Kafka.
io.micronaut.configuration.kafka.embedded - package io.micronaut.configuration.kafka.embedded
Support classes for embedding Kafka within applications and tests.
io.micronaut.configuration.kafka.exceptions - package io.micronaut.configuration.kafka.exceptions
Kafka specific exceptions.
io.micronaut.configuration.kafka.executor - package io.micronaut.configuration.kafka.executor
Classes related to configuring the thread pool to run Kafka consumers.
io.micronaut.configuration.kafka.health - package io.micronaut.configuration.kafka.health
Classes related to performing health checks for Kafka.
io.micronaut.configuration.kafka.intercept - package io.micronaut.configuration.kafka.intercept
Contains the implementation of the KafkaClient introduction advice.
io.micronaut.configuration.kafka.metrics - package io.micronaut.configuration.kafka.metrics
Contains classes specific to capturing Kafka metrics.
io.micronaut.configuration.kafka.processor - package io.micronaut.configuration.kafka.processor
Contains the implementation of KafkaListener.
io.micronaut.configuration.kafka.scope - package io.micronaut.configuration.kafka.scope
Contains the scope implementation for KafkaClient.
io.micronaut.configuration.kafka.serde - package io.micronaut.configuration.kafka.serde
Classes for looking up Kafka Serde instances.
io.micronaut.configuration.kafka.streams - package io.micronaut.configuration.kafka.streams
Contains classes that integrate Micronaut and Kafka Streams.
io.micronaut.configuration.kafka.tracing - package io.micronaut.configuration.kafka.tracing
 
isEnabled() - Method in class io.micronaut.configuration.kafka.embedded.KafkaEmbeddedConfiguration
 
isPaused(String) - Method in interface io.micronaut.configuration.kafka.ConsumerRegistry
Is the consumer with the given ID paused.
isPaused(String) - Method in class io.micronaut.configuration.kafka.processor.KafkaConsumerProcessor
 
isRunning() - Method in class io.micronaut.configuration.kafka.scope.KafkaClientScope
 

J

JsonSerde<T> - Class in io.micronaut.configuration.kafka.serde
A Serializer and Deserializer for JSON.
JsonSerde(JacksonObjectSerializer, Class<T>) - Constructor for class io.micronaut.configuration.kafka.serde.JsonSerde
Constructs a new instance for the given arguments.
JsonSerde(Class<T>) - Constructor for class io.micronaut.configuration.kafka.serde.JsonSerde
Constructs a new instance for the given arguments.
JsonSerde(ObjectMapper, Class<T>) - Constructor for class io.micronaut.configuration.kafka.serde.JsonSerde
Constructs a new instance for the given arguments.
JsonSerdeRegistry - Class in io.micronaut.configuration.kafka.serde
A SerdeRegistry that computes Serde instances that use Jackson to JSON serialization.
JsonSerdeRegistry(BeanContext) - Constructor for class io.micronaut.configuration.kafka.serde.JsonSerdeRegistry
Constructs a new instance.

K

KafkaAcknowledgement - Interface in io.micronaut.configuration.kafka
Defines an interface that can be injected into KafkaListener beans so that offsets can be manually committed.
KafkaBodyBinder<T> - Class in io.micronaut.configuration.kafka.bind
The default binder that binds the body of a ConsumerRecord.
KafkaBodyBinder() - Constructor for class io.micronaut.configuration.kafka.bind.KafkaBodyBinder
 
KafkaClient - Annotation Type in io.micronaut.configuration.kafka.annotation
An introduction advice that automatically implements interfaces and abstract classes and creates KafkaProducer instances.
KafkaClient.Acknowledge - Class in io.micronaut.configuration.kafka.annotation
Constants for the ack setting for the client, which impacts message delivery durability.
KafkaClientIntroductionAdvice - Class in io.micronaut.configuration.kafka.intercept
Implementation of the KafkaClient advice annotation.
KafkaClientIntroductionAdvice(BeanContext, KafkaProducerFactory, SerdeRegistry, ConversionService<?>) - Constructor for class io.micronaut.configuration.kafka.intercept.KafkaClientIntroductionAdvice
Creates the introduction advice for the given arguments.
KafkaClientScope - Class in io.micronaut.configuration.kafka.scope
A scope implementation for injecting Producer instances.
KafkaClientScope(BeanContext, SerdeRegistry) - Constructor for class io.micronaut.configuration.kafka.scope.KafkaClientScope
Constructs a new client scope.
KafkaConsumerAware<K,V> - Interface in io.micronaut.configuration.kafka
Deprecated.
Use ConsumerAware instead.
KafkaConsumerConfiguration<K,V> - Class in io.micronaut.configuration.kafka.config
Configuration for Apache Kafka Consumer.
KafkaConsumerConfiguration(String, KafkaDefaultConfiguration, Environment) - Constructor for class io.micronaut.configuration.kafka.config.KafkaConsumerConfiguration
Construct a new KafkaConsumerConfiguration for the given defaults.
KafkaConsumerFactory - Class in io.micronaut.configuration.kafka
A factory class for creating Kafka Consumer instances.
KafkaConsumerFactory() - Constructor for class io.micronaut.configuration.kafka.KafkaConsumerFactory
 
KafkaConsumerMetrics - Class in io.micronaut.configuration.kafka.metrics
Binds Kafka Metrics to Micrometer.
KafkaConsumerMetrics() - Constructor for class io.micronaut.configuration.kafka.metrics.KafkaConsumerMetrics
 
KafkaConsumerProcessor - Class in io.micronaut.configuration.kafka.processor
A ExecutableMethodProcessor that will process all beans annotated with KafkaListener and create and subscribe the relevant methods as consumers to Kafka topics.
KafkaConsumerProcessor(ExecutorService, ApplicationConfiguration, BeanContext, AbstractKafkaConsumerConfiguration, ConsumerRecordBinderRegistry, BatchConsumerRecordsBinderRegistry, SerdeRegistry, ProducerRegistry, KafkaListenerExceptionHandler) - Constructor for class io.micronaut.configuration.kafka.processor.KafkaConsumerProcessor
Creates a new processor using the given ExecutorService to schedule consumers on.
KafkaConsumerTracingInstrumentation - Class in io.micronaut.configuration.kafka.tracing
Instruments Kafka consumers with Open Tracing support.
KafkaConsumerTracingInstrumentation(Provider<Tracer>) - Constructor for class io.micronaut.configuration.kafka.tracing.KafkaConsumerTracingInstrumentation
Default constructor.
KafkaDefaultBinder<T> - Class in io.micronaut.configuration.kafka.bind
The default binder that binds the Kafka value for a ConsumerRecord.
KafkaDefaultBinder() - Constructor for class io.micronaut.configuration.kafka.bind.KafkaDefaultBinder
Default constructor.
KafkaDefaultConfiguration - Class in io.micronaut.configuration.kafka.config
The default Kafka configuration to apply to both the consumer and the producer, but can be overridden by either.
KafkaDefaultConfiguration(Environment) - Constructor for class io.micronaut.configuration.kafka.config.KafkaDefaultConfiguration
Constructs the default Kafka configuration.
KafkaEmbedded - Class in io.micronaut.configuration.kafka.embedded
This class will configure a Kafka server for the test environment if no server is already available.
KafkaEmbedded(KafkaEmbeddedConfiguration) - Constructor for class io.micronaut.configuration.kafka.embedded.KafkaEmbedded
Construct a new instance.
KafkaEmbeddedConfiguration - Class in io.micronaut.configuration.kafka.embedded
Configuration for the embedded Kafka server.
KafkaEmbeddedConfiguration() - Constructor for class io.micronaut.configuration.kafka.embedded.KafkaEmbeddedConfiguration
 
KafkaHeaderBinder<T> - Class in io.micronaut.configuration.kafka.bind
Binds Kafka headers to arguments.
KafkaHeaderBinder() - Constructor for class io.micronaut.configuration.kafka.bind.KafkaHeaderBinder
 
KafkaHeaderConverter - Class in io.micronaut.configuration.kafka.convert
Converts header values.
KafkaHeaderConverter() - Constructor for class io.micronaut.configuration.kafka.convert.KafkaHeaderConverter
 
KafkaHeaders - Class in io.micronaut.configuration.kafka
A MessageHeaders implementation for Kafka.
KafkaHeaders(Headers) - Constructor for class io.micronaut.configuration.kafka.KafkaHeaders
Constructs a new instance for the given headers.
KafkaHeadersBinder - Class in io.micronaut.configuration.kafka.bind
Obtains the MessageHeaders object for Kafka.
KafkaHeadersBinder() - Constructor for class io.micronaut.configuration.kafka.bind.KafkaHeadersBinder
 
KafkaHealthIndicator - Class in io.micronaut.configuration.kafka.health
A HealthIndicator for Kafka.
KafkaHealthIndicator(AdminClient, KafkaDefaultConfiguration) - Constructor for class io.micronaut.configuration.kafka.health.KafkaHealthIndicator
Constructs a new Kafka health indicator for the given arguments.
KafkaKey - Annotation Type in io.micronaut.configuration.kafka.annotation
Parameter level annotation to indicate which parameter is bound to the Kafka key.
KafkaKeyBinder<T> - Class in io.micronaut.configuration.kafka.bind
Binder for binding the parameters that is designated the KafkaKey.
KafkaKeyBinder() - Constructor for class io.micronaut.configuration.kafka.bind.KafkaKeyBinder
 
KafkaListener - Annotation Type in io.micronaut.configuration.kafka.annotation
Annotation applied at the class level to indicate that a bean is a Kafka Consumer.
KafkaListenerException - Exception in io.micronaut.configuration.kafka.exceptions
Exception thrown when an error occurs processing a ConsumerRecord via a KafkaListener.
KafkaListenerException(String, Object, Consumer<?, ?>, ConsumerRecord<?, ?>) - Constructor for exception io.micronaut.configuration.kafka.exceptions.KafkaListenerException
Creates a new exception.
KafkaListenerException(String, Throwable, Object, Consumer<?, ?>, ConsumerRecord<?, ?>) - Constructor for exception io.micronaut.configuration.kafka.exceptions.KafkaListenerException
Creates a new exception.
KafkaListenerException(Throwable, Object, Consumer<?, ?>, ConsumerRecord<?, ?>) - Constructor for exception io.micronaut.configuration.kafka.exceptions.KafkaListenerException
Creates a new exception.
KafkaListenerExceptionHandler - Interface in io.micronaut.configuration.kafka.exceptions
Interface that KafkaListener beans can implement to handle exceptions.
KafkaMessagingBodyBinder<T> - Class in io.micronaut.configuration.kafka.bind
The default binder that binds the body of a ConsumerRecord.
KafkaMessagingBodyBinder() - Constructor for class io.micronaut.configuration.kafka.bind.KafkaMessagingBodyBinder
 
KafkaProducerConfiguration<K,V> - Class in io.micronaut.configuration.kafka.config
Configuration for Apache Kafka Producer.
KafkaProducerConfiguration(String, KafkaDefaultConfiguration, Environment) - Constructor for class io.micronaut.configuration.kafka.config.KafkaProducerConfiguration
Constructs the default producer configuration.
KafkaProducerFactory - Class in io.micronaut.configuration.kafka
A factory class for creating Kafka Producer instances.
KafkaProducerFactory() - Constructor for class io.micronaut.configuration.kafka.KafkaProducerFactory
 
KafkaProducerMetrics - Class in io.micronaut.configuration.kafka.metrics
 
KafkaProducerMetrics() - Constructor for class io.micronaut.configuration.kafka.metrics.KafkaProducerMetrics
 
KafkaProducerRegistry - Interface in io.micronaut.configuration.kafka
Deprecated.
Use ProducerRegistry instead
KafkaProducerTracingInstrumentation - Class in io.micronaut.configuration.kafka.tracing
Instruments Kafka producers with Open Tracing support.
KafkaProducerTracingInstrumentation(Provider<Tracer>) - Constructor for class io.micronaut.configuration.kafka.tracing.KafkaProducerTracingInstrumentation
Default constructor.
KafkaStreamsConfiguration<K,V> - Class in io.micronaut.configuration.kafka.streams
The default configuration passed to KafkaStreams.
KafkaStreamsConfiguration(String, KafkaDefaultConfiguration, ApplicationConfiguration, Environment) - Constructor for class io.micronaut.configuration.kafka.streams.KafkaStreamsConfiguration
Construct a new KafkaStreamsConfiguration for the given defaults.
KafkaStreamsFactory - Class in io.micronaut.configuration.kafka.streams
A factory that constructs the KafkaStreams bean.
KafkaStreamsFactory() - Constructor for class io.micronaut.configuration.kafka.streams.KafkaStreamsFactory
 

N

nack() - Method in interface io.micronaut.configuration.kafka.KafkaAcknowledgement
Kafka does not support rejection of messages explicitly.
names() - Method in class io.micronaut.configuration.kafka.KafkaHeaders
 
NONE - Static variable in class io.micronaut.configuration.kafka.annotation.KafkaClient.Acknowledge
Don't wait for the server to acknowledge receipt.

O

OffsetReset - Enum in io.micronaut.configuration.kafka.annotation
Sets the value of the auto.offset.reset property for a Kafka consumer.
OffsetStrategy - Enum in io.micronaut.configuration.kafka.annotation
An enum representing different strategies for committing offsets to Kafka when using KafkaListener.
onCreated(BeanCreatedEvent<AbstractKafkaConfiguration>) - Method in class io.micronaut.configuration.kafka.embedded.KafkaEmbedded
 
onCreated(BeanCreatedEvent<AbstractKafkaConsumerConfiguration>) - Method in class io.micronaut.configuration.kafka.metrics.KafkaConsumerMetrics
 
onCreated(BeanCreatedEvent<AbstractKafkaProducerConfiguration>) - Method in class io.micronaut.configuration.kafka.metrics.KafkaProducerMetrics
 
onCreated(BeanCreatedEvent<Consumer<?, ?>>) - Method in class io.micronaut.configuration.kafka.tracing.KafkaConsumerTracingInstrumentation
 
onCreated(BeanCreatedEvent<Producer<?, ?>>) - Method in class io.micronaut.configuration.kafka.tracing.KafkaProducerTracingInstrumentation
 
ONE - Static variable in class io.micronaut.configuration.kafka.annotation.KafkaClient.Acknowledge
Wait for the leader to acknowledge.

P

pause(String) - Method in interface io.micronaut.configuration.kafka.ConsumerRegistry
Pause the consumer for the given ID.
pause(String) - Method in class io.micronaut.configuration.kafka.processor.KafkaConsumerProcessor
 
pickDeserializer(Argument<T>) - Method in interface io.micronaut.configuration.kafka.serde.SerdeRegistry
Picks the most appropriate Deserializer for the given argument.
pickSerializer(Argument<T>) - Method in interface io.micronaut.configuration.kafka.serde.SerdeRegistry
Picks the most appropriate Deserializer for the given argument.
PREFIX - Static variable in class io.micronaut.configuration.kafka.config.AbstractKafkaConfiguration
The default prefix used for Kafka configuration.
PREFIX - Static variable in class io.micronaut.configuration.kafka.config.KafkaConsumerConfiguration
The default consumers configuration.
PREFIX - Static variable in class io.micronaut.configuration.kafka.config.KafkaProducerConfiguration
The default configuration for producers.
PREFIX - Static variable in class io.micronaut.configuration.kafka.embedded.KafkaEmbeddedConfiguration
The prefix used for configuration.
PREFIX - Static variable in class io.micronaut.configuration.kafka.streams.KafkaStreamsConfiguration
The default streams configuration.
process(BeanDefinition<?>, ExecutableMethod<?, ?>) - Method in class io.micronaut.configuration.kafka.processor.KafkaConsumerProcessor
 
ProducerKafkaMetricsReporter - Class in io.micronaut.configuration.kafka.metrics
A MetricsReporter class for producer metrics.
ProducerKafkaMetricsReporter() - Constructor for class io.micronaut.configuration.kafka.metrics.ProducerKafkaMetricsReporter
 
ProducerRegistry - Interface in io.micronaut.configuration.kafka
A registry of managed Producer instances key by id and type.

R

remove(CharSequence) - Method in class io.micronaut.configuration.kafka.KafkaHeaders
 
remove(BeanIdentifier) - Method in class io.micronaut.configuration.kafka.scope.KafkaClientScope
 
resume(String) - Method in interface io.micronaut.configuration.kafka.ConsumerRegistry
Resume the consumer for the given ID.
resume(String) - Method in class io.micronaut.configuration.kafka.processor.KafkaConsumerProcessor
 

S

seekPastDeserializationError(SerializationException, Object, Consumer<?, ?>) - Method in class io.micronaut.configuration.kafka.exceptions.DefaultKafkaListenerExceptionHandler
Seeks past a serialization exception if an error occurs.
SerdeRegistry - Interface in io.micronaut.configuration.kafka.serde
A registry of Kafka Serde instances.
serialize(String, T) - Method in class io.micronaut.configuration.kafka.serde.JsonSerde
 
serializer() - Method in class io.micronaut.configuration.kafka.serde.JsonSerde
 
setEnabled(boolean) - Method in class io.micronaut.configuration.kafka.embedded.KafkaEmbeddedConfiguration
Sets whether the embedded Kafka server is enabled.
setHealthTimeout(Duration) - Method in class io.micronaut.configuration.kafka.config.KafkaDefaultConfiguration
The health check timeout.
setKafkaConsumer(Consumer<K, V>) - Method in interface io.micronaut.configuration.kafka.ConsumerAware
Called when the underlying Consumer is created.
setKafkaConsumer(KafkaConsumer<K, V>) - Method in interface io.micronaut.configuration.kafka.KafkaConsumerAware
Deprecated.
Called when the underlying KafkaConsumer is created.
setKafkaConsumer(Consumer<K, V>) - Method in interface io.micronaut.configuration.kafka.KafkaConsumerAware
Deprecated.
 
setKeyDeserializer(Deserializer<K>) - Method in class io.micronaut.configuration.kafka.config.AbstractKafkaConsumerConfiguration
Sets the key deserializer.
setKeySerializer(Serializer<K>) - Method in class io.micronaut.configuration.kafka.config.AbstractKafkaProducerConfiguration
Sets the key serializer.
setProperties(Properties) - Method in class io.micronaut.configuration.kafka.embedded.KafkaEmbeddedConfiguration
Sets the broker properties.
setSkipRecordOnDeserializationFailure(boolean) - Method in class io.micronaut.configuration.kafka.exceptions.DefaultKafkaListenerExceptionHandler
Sets whether the seek past records that are not deserializable.
setTopics(List<String>) - Method in class io.micronaut.configuration.kafka.embedded.KafkaEmbeddedConfiguration
The topics that should be created by the embedded instance.
setValueDeserializer(Deserializer<V>) - Method in class io.micronaut.configuration.kafka.config.AbstractKafkaConsumerConfiguration
Sets the default value deserializer.
setValueSerializer(Serializer<V>) - Method in class io.micronaut.configuration.kafka.config.AbstractKafkaProducerConfiguration
Sets the default value serializer.
stop() - Method in class io.micronaut.configuration.kafka.scope.KafkaClientScope
 

T

Topic - Annotation Type in io.micronaut.configuration.kafka.annotation
Method level annotation used to specify which topics should be subscribed to.
Topics - Annotation Type in io.micronaut.configuration.kafka.annotation
Repeatable annotation for one or many Topic annotations.
toString() - Method in class io.micronaut.configuration.kafka.serde.JsonSerde
 
TYPE - Static variable in class io.micronaut.configuration.kafka.bind.KafkaHeadersBinder
 
TypedConsumerRecordBinder<T> - Interface in io.micronaut.configuration.kafka.bind
Allows binding by type.

V

valueOf(String) - Static method in enum io.micronaut.configuration.kafka.annotation.OffsetReset
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.micronaut.configuration.kafka.annotation.OffsetStrategy
Returns the enum constant of this type with the specified name.
values() - Static method in enum io.micronaut.configuration.kafka.annotation.OffsetReset
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.micronaut.configuration.kafka.annotation.OffsetStrategy
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Method in class io.micronaut.configuration.kafka.KafkaHeaders
 
A B C D E F G H I J K N O P R S T V 
Skip navigation links