Index

A B C D E F G H I J K L M N O P R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

ABSOLUTE - Enum constant in enum class io.micronaut.configuration.kafka.seek.KafkaSeekOperation.OffsetType
The offset is absolute.
AbstractKafkaApplicationEvent<T> - Class in io.micronaut.configuration.kafka.event
Abstract base class for all kafka application events.
AbstractKafkaApplicationEvent(T) - Constructor for class io.micronaut.configuration.kafka.event.AbstractKafkaApplicationEvent
Constructs a prototypical Event.
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.
AbstractKafkaMetrics<T extends AbstractKafkaConfiguration> - Class in io.micronaut.configuration.kafka.metrics
A class to simplify the producer and consumer metric.reporters default property.
AbstractKafkaMetrics() - Constructor for class io.micronaut.configuration.kafka.metrics.AbstractKafkaMetrics
 
AbstractKafkaMetricsReporter - Class in io.micronaut.configuration.kafka.metrics
A MetricsReporter that binds metrics to micrometer.
AbstractKafkaMetricsReporter() - Constructor for class io.micronaut.configuration.kafka.metrics.AbstractKafkaMetricsReporter
 
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.
AbstractKafkaStreamsEvent - Class in io.micronaut.configuration.kafka.streams.event
Abstract class for kafka streams events.
AbstractKafkaStreamsEvent(KafkaStreams) - Constructor for class io.micronaut.configuration.kafka.streams.event.AbstractKafkaStreamsEvent
Default constructor.
Acknowledge() - Constructor for class io.micronaut.configuration.kafka.annotation.KafkaClient.Acknowledge
 
acks() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaClient
 
add(CharSequence, CharSequence) - Method in class io.micronaut.configuration.kafka.KafkaHeaders
 
addKafkaMetrics(BeanCreatedEvent<T>, String) - Method in class io.micronaut.configuration.kafka.metrics.AbstractKafkaMetrics
Method to add a default metric reporter if not otherwise defined.
addKafkaMetrics(BeanCreatedEvent<T>, String, MeterRegistry) - Method in class io.micronaut.configuration.kafka.metrics.AbstractKafkaMetrics
Method to add a default metric reporter if not otherwise defined.
AdminClientFactory - Class in io.micronaut.configuration.kafka.admin
Creates the Kafka AdminClient.
AdminClientFactory() - Constructor for class io.micronaut.configuration.kafka.admin.AdminClientFactory
 
AfterKafkaStreamsStart - Class in io.micronaut.configuration.kafka.streams.event
Event fired after the Kafka streams have started.
AfterKafkaStreamsStart(KafkaStreams, KStream<?, ?>[]) - Constructor for class io.micronaut.configuration.kafka.streams.event.AfterKafkaStreamsStart
Default constructor.
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 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.KafkaKeyBinder
 
annotationType() - Method in class io.micronaut.configuration.kafka.bind.KafkaMessageHeaderBinder
 
annotationType() - Method in class io.micronaut.configuration.kafka.bind.KafkaMessagingBodyBinder
 
annotationType() - Method in class io.micronaut.configuration.kafka.bind.KafkaPartitionBinder
 
argumentType() - Method in class io.micronaut.configuration.kafka.bind.KafkaHeadersBinder
 
ASYNC - Enum constant in enum class io.micronaut.configuration.kafka.annotation.OffsetStrategy
Asynchronously commit offsets using Consumer.commitAsync() after each batch of messages is processed.
ASYNC_PER_RECORD - Enum constant in enum class io.micronaut.configuration.kafka.annotation.OffsetStrategy
Asynchronously commit offsets using Consumer.commitSync() after each ConsumerRecord is processed.
AUTO - Enum constant in enum class io.micronaut.configuration.kafka.annotation.OffsetStrategy
Automatically commit offsets with the Consumer.poll(java.time.Duration) loop.
autoStartup() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaListener
Setting to allow start the consumer in paused mode.

B

BACKWARD - Enum constant in enum class io.micronaut.configuration.kafka.seek.KafkaSeekOperation.OffsetType
The offset goes backward, relative to the current position.
batch() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaClient
By default when specifying an array or List the object will be serializes to a JSON array.
batch() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaListener
By default each listener will consume a single ConsumerRecord.
BatchConsumerRecordsBinderRegistry - Class in io.micronaut.configuration.kafka.bind.batch
Binds arguments in batches from a ConsumerRecords instance.
BatchConsumerRecordsBinderRegistry(ConsumerRecordBinderRegistry, ConversionService) - Constructor for class io.micronaut.configuration.kafka.bind.batch.BatchConsumerRecordsBinderRegistry
Constructs a new instance.
BeforeKafkaStreamStart - Class in io.micronaut.configuration.kafka.streams.event
An event fired before a KafkaStreams object starts.
BeforeKafkaStreamStart(KafkaStreams, KStream<?, ?>[]) - Constructor for class io.micronaut.configuration.kafka.streams.event.BeforeKafkaStreamStart
Default constructor.
BEGINNING - Enum constant in enum class io.micronaut.configuration.kafka.seek.KafkaSeekOperation.OffsetType
The offset goes forward, relative to the beginning of the partition.
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.KafkaDefaultBinder
 
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.KafkaMessageHeaderBinder
 
bind(ArgumentConversionContext<T>, ConsumerRecord<?, ?>) - Method in class io.micronaut.configuration.kafka.bind.KafkaMessagingBodyBinder
 
bind(ArgumentConversionContext<T>, ConsumerRecord<?, ?>) - Method in class io.micronaut.configuration.kafka.bind.KafkaPartitionBinder
 
bindTo(MeterRegistry) - Method in class io.micronaut.configuration.kafka.metrics.AbstractKafkaMetricsReporter
 
body(V) - Method in class io.micronaut.configuration.kafka.KafkaMessage.Builder
 
BraveKafkaConsumerTracingInstrumentation - Class in io.micronaut.configuration.kafka.tracing.brave
Kafka consumer tracing instrumentation using Brave.
BraveKafkaConsumerTracingInstrumentation(KafkaTracing) - Constructor for class io.micronaut.configuration.kafka.tracing.brave.BraveKafkaConsumerTracingInstrumentation
Default constructor.
BraveKafkaProducerTracingInstrumentation - Class in io.micronaut.configuration.kafka.tracing.brave
Kafka producer tracing instrumentation using Brave.
BraveKafkaProducerTracingInstrumentation(KafkaTracing) - Constructor for class io.micronaut.configuration.kafka.tracing.brave.BraveKafkaProducerTracingInstrumentation
Default constructor.
BraveKafkaTracingFactory - Class in io.micronaut.configuration.kafka.tracing.brave
Brave's Kafka tracing factory.
BraveKafkaTracingFactory() - Constructor for class io.micronaut.configuration.kafka.tracing.brave.BraveKafkaTracingFactory
 
build() - Method in class io.micronaut.configuration.kafka.KafkaMessage.Builder
 
build() - Method in class io.micronaut.configuration.kafka.metrics.builder.KafkaMetricMeterTypeBuilder
Build and register a typed meter.
Builder() - Constructor for class io.micronaut.configuration.kafka.KafkaMessage.Builder
 

C

CLIENT_ID_TAG - Static variable in class io.micronaut.configuration.kafka.metrics.AbstractKafkaMetricsReporter
 
clientId() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaListener
Sets the client id of the Kafka consumer.
close() - Method in class io.micronaut.configuration.kafka.metrics.AbstractKafkaMetricsReporter
 
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.serde.JsonObjectSerde
 
close() - Method in class io.micronaut.configuration.kafka.streams.KafkaStreamsFactory
 
close() - Method in class io.micronaut.configuration.kafka.streams.metrics.KafkaStreamsMetricsReporter
Method to close bean.
close(Producer<?, ?>) - Method in interface io.micronaut.configuration.kafka.TransactionalProducerRegistry
Closed the producer.
close(Producer<?, ?>) - Method in class io.micronaut.configuration.kafka.KafkaProducerFactory
 
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.
computeRetryDelay(Duration, long) - Method in enum class io.micronaut.configuration.kafka.annotation.ErrorStrategyValue
Compute retry delay given a fixed delay and the number of attempts.
conditionalRetryBehaviour(KafkaListenerException) - Method in interface io.micronaut.configuration.kafka.retry.ConditionalRetryBehaviourHandler
Returns the seek behaviour for the given exception.
conditionalRetryBehaviour(KafkaListenerException) - Method in class io.micronaut.configuration.kafka.retry.DefaultConditionalRetryBehaviourHandler
Retries the record by default.
ConditionalRetryBehaviourHandler - Interface in io.micronaut.configuration.kafka.retry
Interface that can be implemented to provide conditional retry behaviour for a KafkaConsumer when a ConsumerRecord fails to be processed and the error strategy is set to conditionally retry.
ConditionalRetryBehaviourHandler.ConditionalRetryBehaviour - Enum Class in io.micronaut.configuration.kafka.retry
The conditional retry behaviours.
configure(Map<String, ?>) - Method in class io.micronaut.configuration.kafka.metrics.AbstractKafkaMetricsReporter
 
configure(Map<String, ?>, boolean) - Method in class io.micronaut.configuration.kafka.serde.JsonObjectSerde
 
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
ConfiguredStreamBuilder(Properties, String, Duration) - 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
Deprecated.
Use conversion service constructor instead.
ConsumerRecordBinderRegistry(ConversionService, 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.
ConsumerSeekAware - Interface in io.micronaut.configuration.kafka
Interface for KafkaListener instances to implement if they wish to perform seek operations when the set of partitions assigned to the Consumer changes.
convert(Header, Class<Object>, ConversionContext) - Method in class io.micronaut.configuration.kafka.convert.KafkaHeaderConverter
 
create(ClusterResourceListener...) - Method in class io.micronaut.configuration.kafka.health.DefaultNetworkClientCreator
 
create(ClusterResourceListener...) - Method in interface io.micronaut.configuration.kafka.health.NetworkClientCreator
 
createConsumer(AbstractKafkaConsumerConfiguration<K, V>) - Method in class io.micronaut.configuration.kafka.KafkaConsumerFactory
Creates a new KafkaConsumer for the given configuration.
createProducer(Properties, Serializer<K>, Serializer<V>) - Method in class io.micronaut.configuration.kafka.DefaultProducerFactory
Creates kafka producer, could be overridden for further control.
createProducer(Properties, Serializer<K>, Serializer<V>) - Method in interface io.micronaut.configuration.kafka.ProducerFactory
Creates kafka producer, could be overridden for further control.

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_CLOSE_TIMEOUT - Static variable in class io.micronaut.configuration.kafka.streams.AbstractKafkaStreamsConfiguration
 
DEFAULT_COMMIT_RECORD_ON_DESERIALIZATION_FAILURE - Static variable in class io.micronaut.configuration.kafka.config.DefaultKafkaListenerExceptionHandlerConfigurationProperties
The default value for commitRecordOnDeserializationFailure.
DEFAULT_DELAY_IN_SECONDS - Static variable in annotation interface io.micronaut.configuration.kafka.annotation.ErrorStrategy
Default retry delay in seconds.
DEFAULT_ENABLED - Static variable in class io.micronaut.configuration.kafka.config.KafkaHealthConfigurationProperties
The default enable value.
DEFAULT_HANDLE_ALL_EXCEPTIONS - Static variable in annotation interface io.micronaut.configuration.kafka.annotation.ErrorStrategy
Default handle all exceptions.
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.
DEFAULT_NAME - Static variable in class io.micronaut.configuration.kafka.streams.AbstractKafkaStreamsConfiguration
 
DEFAULT_RESTRICTED - Static variable in class io.micronaut.configuration.kafka.config.KafkaHealthConfigurationProperties
The default restricted value.
DEFAULT_RETRY_COUNT - Static variable in annotation interface io.micronaut.configuration.kafka.annotation.ErrorStrategy
Default retry attempts.
DEFAULT_SKIP_RECORD_ON_DESERIALIZATION_FAILURE - Static variable in class io.micronaut.configuration.kafka.config.DefaultKafkaListenerExceptionHandlerConfigurationProperties
The default value for skipRecordOnDeserializationFailure.
DefaultConditionalRetryBehaviourHandler - Class in io.micronaut.configuration.kafka.retry
The default ConditionalRetryBehaviourHandler used when a KafkaConsumer fails to process a ConsumerRecord and the error strategy is set to conditionally retry.
DefaultConditionalRetryBehaviourHandler() - Constructor for class io.micronaut.configuration.kafka.retry.DefaultConditionalRetryBehaviourHandler
 
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(AbstractKafkaConfiguration) - Constructor for class io.micronaut.configuration.kafka.config.DefaultKafkaConsumerConfiguration
Construct a new KafkaConsumerConfiguration for the given defaults.
DefaultKafkaConsumerConfiguration(KafkaDefaultConfiguration) - 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
Deprecated, for removal: This API element is subject to removal in a future version.
DefaultKafkaListenerExceptionHandler(DefaultKafkaListenerExceptionHandlerConfiguration) - Constructor for class io.micronaut.configuration.kafka.exceptions.DefaultKafkaListenerExceptionHandler
Creates a new instance.
DefaultKafkaListenerExceptionHandlerConfiguration - Interface in io.micronaut.configuration.kafka.config
Default Kafka listener exception handler configuration.
DefaultKafkaListenerExceptionHandlerConfigurationProperties - Class in io.micronaut.configuration.kafka.config
ConfigurationProperties implementation of DefaultKafkaListenerExceptionHandlerConfiguration.
DefaultKafkaListenerExceptionHandlerConfigurationProperties() - Constructor for class io.micronaut.configuration.kafka.config.DefaultKafkaListenerExceptionHandlerConfigurationProperties
 
DefaultKafkaProducerConfiguration<K,V> - Class in io.micronaut.configuration.kafka.config
The default KafkaProducer configuration when no default is specified.
DefaultKafkaProducerConfiguration(AbstractKafkaConfiguration) - Constructor for class io.micronaut.configuration.kafka.config.DefaultKafkaProducerConfiguration
Construct a new KafkaConsumerConfiguration for the given defaults.
DefaultKafkaProducerConfiguration(KafkaDefaultConfiguration) - Constructor for class io.micronaut.configuration.kafka.config.DefaultKafkaProducerConfiguration
Constructs a new instance.
DefaultKafkaStreamsConfiguration<K,V> - Class in io.micronaut.configuration.kafka.streams
The default streams configuration if no other is present.
DefaultKafkaStreamsConfiguration(KafkaDefaultConfiguration, ApplicationConfiguration, Environment) - Constructor for class io.micronaut.configuration.kafka.streams.DefaultKafkaStreamsConfiguration
Construct a new KafkaStreamsConfiguration for the given defaults.
DefaultNetworkClientCreator - Class in io.micronaut.configuration.kafka.health
Default implementation of NetworkClientCreator.
DefaultNetworkClientCreator(KafkaDefaultConfiguration) - Constructor for class io.micronaut.configuration.kafka.health.DefaultNetworkClientCreator
 
DefaultProducerFactory - Class in io.micronaut.configuration.kafka
A default implementation of ProducerFactory used for creating producer.
DefaultProducerFactory() - Constructor for class io.micronaut.configuration.kafka.DefaultProducerFactory
 
defer(KafkaSeekOperation) - Method in interface io.micronaut.configuration.kafka.seek.KafkaSeekOperations
Adds a KafkaSeekOperation to the list.
deserialize(String, byte[]) - Method in class io.micronaut.configuration.kafka.serde.JsonObjectSerde
 
deserializer() - Method in class io.micronaut.configuration.kafka.serde.JsonObjectSerde
 
DISABLED - Enum constant in enum class io.micronaut.configuration.kafka.annotation.OffsetStrategy
Do not commit offsets.

E

EARLIEST - Enum constant in enum class io.micronaut.configuration.kafka.annotation.OffsetReset
Earliest means that a consumer will start reading the earliest available records for a topic.
EMBEDDED_TOPICS - Static variable in class io.micronaut.configuration.kafka.config.AbstractKafkaConfiguration
The topics that should be created.
EMPTY_OPTIONAL - Static variable in class io.micronaut.configuration.kafka.bind.KafkaMessageHeaderBinder
 
ENABLED_PROPERTY - Static variable in class io.micronaut.configuration.kafka.streams.health.KafkaStreamsHealth
 
END - Enum constant in enum class io.micronaut.configuration.kafka.seek.KafkaSeekOperation.OffsetType
The offset goes backward, relative to the end of the partition.
errorStrategy() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaListener
Setting the error strategy allows you to resume at the next offset or to seek the consumer (stop on error) to the failed offset so that it can retry if an error occurs The consumer bean is still able to implement a custom exception handler to replace DefaultKafkaListenerExceptionHandler and set the error strategy.
ErrorStrategy - Annotation Interface in io.micronaut.configuration.kafka.annotation
Setting the error strategy allows you to resume at the next offset or to seek the consumer (stop on error) to the failed offset so that it can retry if an error occurs.
ErrorStrategyValue - Enum Class in io.micronaut.configuration.kafka.annotation
Defines the type of error handling strategy that micronaut-kafka will perform in case of error.
exceptionTypes() - Element in annotation interface io.micronaut.configuration.kafka.annotation.ErrorStrategy
The types of exceptions to retry, used with RETRY_ON_ERROR and RETRY_EXPONENTIALLY_ON_ERROR, see ErrorStrategyValue.
executor() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaClient
The executor to use to enable non-blocking producer methods.

F

findArgumentBinder(Argument<T>) - Method in class io.micronaut.configuration.kafka.bind.batch.BatchConsumerRecordsBinderRegistry
 
findArgumentBinder(Argument<T>) - Method in class io.micronaut.configuration.kafka.bind.ConsumerRecordBinderRegistry
 
FORWARD - Enum constant in enum class io.micronaut.configuration.kafka.seek.KafkaSeekOperation.OffsetType
The offset goes forward, relative to the current position.
fromKafkaFuture(Supplier<KafkaFuture<T>>) - Static method in class io.micronaut.configuration.kafka.reactor.KafkaReactorUtil
Factory for creating Mono instances from Kafka Future instances.
FUNCTION_COUNTER - Enum constant in enum class io.micronaut.configuration.kafka.metrics.builder.MeterType
 

G

GAUGE - Enum constant in enum class io.micronaut.configuration.kafka.metrics.builder.MeterType
 
get(CharSequence) - Method in class io.micronaut.configuration.kafka.KafkaHeaders
 
get(CharSequence, ArgumentConversionContext<T>) - Method in class io.micronaut.configuration.kafka.KafkaHeaders
 
getAll(CharSequence) - Method in class io.micronaut.configuration.kafka.KafkaHeaders
 
getBody() - Method in class io.micronaut.configuration.kafka.KafkaMessage
 
getCloseTimeout() - Method in class io.micronaut.configuration.kafka.streams.AbstractKafkaStreamsConfiguration
The time to wait for the stream to shut down.
getCloseTimeout() - Method in class io.micronaut.configuration.kafka.streams.ConfiguredStreamBuilder
The timeout to use when closing the stream.
getClusterReplicationFactor(Config) - Static method in class io.micronaut.configuration.kafka.health.KafkaHealthIndicator
Retrieve the cluster "offsets.topic.replication.factor" for the given Config, falling back to "default.replication.factor" if required, in order to support Confluent Cloud hosted Kafka.
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.
getConsumerAssignment(String) - Method in interface io.micronaut.configuration.kafka.ConsumerRegistry
Returns a managed Consumer's assignment info.
getConsumerIds() - Method in interface io.micronaut.configuration.kafka.ConsumerRegistry
The IDs of the available consumers.
getConsumerRecord() - Method in exception io.micronaut.configuration.kafka.exceptions.KafkaListenerException
 
getConsumerRecords() - Method in exception io.micronaut.configuration.kafka.exceptions.KafkaListenerException
 
getConsumerSubscription(String) - Method in interface io.micronaut.configuration.kafka.ConsumerRegistry
Returns a managed Consumer's subscriptions.
getDeserializer(Class<T>) - Method in interface io.micronaut.configuration.kafka.serde.SerdeRegistry
Obtain a Deserializer for the given type.
getExecutor() - Method in class io.micronaut.configuration.kafka.config.AbstractKafkaProducerConfiguration
 
getHeaders() - Method in class io.micronaut.configuration.kafka.KafkaMessage
 
getHealthTimeout() - Method in class io.micronaut.configuration.kafka.config.KafkaDefaultConfiguration
The health check timeout.
getIncludedTags() - Method in class io.micronaut.configuration.kafka.metrics.AbstractKafkaMetricsReporter
The tags to include in the gauge.
getIncludedTags() - Method in class io.micronaut.configuration.kafka.metrics.ConsumerKafkaMetricsReporter
 
getKafkaConsumer() - Method in exception io.micronaut.configuration.kafka.exceptions.KafkaListenerException
 
getKafkaListener() - Method in exception io.micronaut.configuration.kafka.exceptions.KafkaListenerException
 
getKafkaStreams() - Method in class io.micronaut.configuration.kafka.streams.event.AbstractKafkaStreamsEvent
 
getKey() - Method in class io.micronaut.configuration.kafka.KafkaMessage
 
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.AbstractKafkaMetricsReporter
Abstract method to implement with the metric prefix for the reporter.
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.
getMetricPrefix() - Method in class io.micronaut.configuration.kafka.streams.metrics.KafkaStreamsMetricsReporter
 
getMinNodeCount(Config) - Static method in class io.micronaut.configuration.kafka.health.KafkaHealthIndicator
Retrieve the cluster "min.insync.replicas" for the given Config, falling back to "offsets.topic.replication.factor" or "default.replication.factor" if required, in order to support Confluent Cloud hosted Kafka.
getName() - Method in class io.micronaut.configuration.kafka.streams.AbstractKafkaStreamsConfiguration
The logical name of the stream.
getName() - Method in class io.micronaut.configuration.kafka.streams.ConfiguredStreamBuilder
The logical name of the stream.
getPartition() - Method in class io.micronaut.configuration.kafka.KafkaMessage
 
getProducer(InjectionPoint<KafkaProducer<K, V>>, AbstractKafkaProducerConfiguration<K, V>) - Method in class io.micronaut.configuration.kafka.KafkaProducerFactory
Creates a new KafkaProducer for the given configuration.
getProducer(String, Argument<K>, Argument<V>) - Method in class io.micronaut.configuration.kafka.KafkaProducerFactory
 
getProducer(String, Argument<K>, Argument<V>) - Method in interface io.micronaut.configuration.kafka.ProducerRegistry
Returns a managed Producer.
getQueryableStore(String, QueryableStoreType<T>) - Method in class io.micronaut.configuration.kafka.streams.InteractiveQueryService
Retrieve and return a queryable store by name created in the application.
getResult() - Method in class io.micronaut.configuration.kafka.admin.KafkaNewTopics
 
getResult() - Method in class io.micronaut.configuration.kafka.health.KafkaHealthIndicator
 
getResult() - Method in class io.micronaut.configuration.kafka.streams.health.KafkaStreamsHealth
Get the health result of the streams.
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.
getSource() - Method in class io.micronaut.configuration.kafka.event.AbstractKafkaApplicationEvent
 
getStreams() - Method in class io.micronaut.configuration.kafka.streams.event.AfterKafkaStreamsStart
 
getStreams() - Method in class io.micronaut.configuration.kafka.streams.event.BeforeKafkaStreamStart
 
getStreams() - Method in class io.micronaut.configuration.kafka.streams.KafkaStreamsFactory
Get configured stream and builder for the stream.
getTimestamp() - Method in class io.micronaut.configuration.kafka.KafkaMessage
 
getTopic() - Method in class io.micronaut.configuration.kafka.KafkaMessage
 
getTransactionalProducer(String, String, Argument<K>, Argument<V>) - Method in interface io.micronaut.configuration.kafka.TransactionalProducerRegistry
Returns a transactional managed Producer.
getTransactionalProducer(String, String, Argument<K>, Argument<V>) - Method in class io.micronaut.configuration.kafka.KafkaProducerFactory
 
getValueDeserializer() - Method in class io.micronaut.configuration.kafka.config.AbstractKafkaConsumerConfiguration
 
getValueSerializer() - Method in class io.micronaut.configuration.kafka.config.AbstractKafkaProducerConfiguration
 
groupId() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaListener

H

handle(KafkaListenerException) - Method in class io.micronaut.configuration.kafka.exceptions.DefaultKafkaListenerExceptionHandler
 
handleAllExceptions() - Element in annotation interface io.micronaut.configuration.kafka.annotation.ErrorStrategy
Whether all exceptions should be handled or ignored when using RETRY_ON_ERROR and RETRY_EXPONENTIALLY_ON_ERROR ErrorStrategyValue.
header(Map<String, Object>) - Method in class io.micronaut.configuration.kafka.KafkaMessage.Builder
 
heartbeatInterval() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaListener
The heart beat interval for the consumer.

I

id() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaClient
 
init(ApplicationConfiguration, Environment, Properties) - Method in class io.micronaut.configuration.kafka.streams.AbstractKafkaStreamsConfiguration
Shared initialization.
init(List<KafkaMetric>) - Method in class io.micronaut.configuration.kafka.metrics.AbstractKafkaMetricsReporter
 
InteractiveQueryService - Class in io.micronaut.configuration.kafka.streams
Services to facilitate the interactive query capabilities of Kafka Streams.
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.event - package io.micronaut.configuration.kafka.event
 
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.metrics - package io.micronaut.configuration.kafka.metrics
Contains classes specific to capturing Kafka metrics.
io.micronaut.configuration.kafka.metrics.builder - package io.micronaut.configuration.kafka.metrics.builder
Contains classes specific to capturing Kafka metric builders.
io.micronaut.configuration.kafka.reactor - package io.micronaut.configuration.kafka.reactor
 
io.micronaut.configuration.kafka.retry - package io.micronaut.configuration.kafka.retry
 
io.micronaut.configuration.kafka.seek - package io.micronaut.configuration.kafka.seek
 
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.streams.event - package io.micronaut.configuration.kafka.streams.event
 
io.micronaut.configuration.kafka.streams.health - package io.micronaut.configuration.kafka.streams.health
 
io.micronaut.configuration.kafka.streams.metrics - package io.micronaut.configuration.kafka.streams.metrics
 
io.micronaut.configuration.kafka.tracing.brave - package io.micronaut.configuration.kafka.tracing.brave
 
isCommitRecordOnDeserializationFailure() - Method in interface io.micronaut.configuration.kafka.config.DefaultKafkaListenerExceptionHandlerConfiguration
 
isCommitRecordOnDeserializationFailure() - Method in class io.micronaut.configuration.kafka.config.DefaultKafkaListenerExceptionHandlerConfigurationProperties
 
isConditionalRetry() - Method in enum class io.micronaut.configuration.kafka.annotation.ErrorStrategyValue
 
isEnabled() - Method in class io.micronaut.configuration.kafka.config.KafkaHealthConfigurationProperties
 
isolation() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaListener
Kafka consumer isolation level to control how to read messages written transactionally.
isPaused(String) - Method in interface io.micronaut.configuration.kafka.ConsumerRegistry
Is the consumer with the given ID paused.
isPaused(String, Collection<TopicPartition>) - Method in interface io.micronaut.configuration.kafka.ConsumerRegistry
Is the consumer with the given ID paused to consume from the given topic partitions.
isRestricted() - Method in interface io.micronaut.configuration.kafka.config.KafkaHealthConfiguration
By default, the health check requires cluster-wide permissions in order to get information about the nodes in the Kafka cluster.
isRestricted() - Method in class io.micronaut.configuration.kafka.config.KafkaHealthConfigurationProperties
 
isRetry() - Method in enum class io.micronaut.configuration.kafka.annotation.ErrorStrategyValue
 
isSkipRecordOnDeserializationFailure() - Method in interface io.micronaut.configuration.kafka.config.DefaultKafkaListenerExceptionHandlerConfiguration
 
isSkipRecordOnDeserializationFailure() - Method in class io.micronaut.configuration.kafka.config.DefaultKafkaListenerExceptionHandlerConfigurationProperties
 

J

JsonObjectSerde<T> - Class in io.micronaut.configuration.kafka.serde
A Serializer and Deserializer for JSON.
JsonObjectSerde(JsonObjectSerializer, Class<T>) - Constructor for class io.micronaut.configuration.kafka.serde.JsonObjectSerde
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.
KafkaClient - Annotation Interface 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.
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(BeanLocator) - Constructor for class io.micronaut.configuration.kafka.metrics.KafkaConsumerMetrics
Default constructor.
KafkaConsumerStartedPollingEvent - Class in io.micronaut.configuration.kafka.event
An event fired after a Kafka Consumer executes the first polling.
KafkaConsumerStartedPollingEvent(Consumer) - Constructor for class io.micronaut.configuration.kafka.event.KafkaConsumerStartedPollingEvent
Constructs an event with a given Consumer source.
KafkaConsumerSubscribedEvent - Class in io.micronaut.configuration.kafka.event
An event fired after a Kafka Consumer subscribes to a set of Kafka topics.
KafkaConsumerSubscribedEvent(Consumer) - Constructor for class io.micronaut.configuration.kafka.event.KafkaConsumerSubscribedEvent
Constructs an event with a given Consumer source.
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.
KafkaHeaderConverter - Class in io.micronaut.configuration.kafka.convert
Converts header values.
KafkaHeaderConverter(ConversionService) - Constructor for class io.micronaut.configuration.kafka.convert.KafkaHeaderConverter
Default constructor.
KafkaHeaders - Class in io.micronaut.configuration.kafka
A MessageHeaders implementation for Kafka.
KafkaHeaders(Headers) - Constructor for class io.micronaut.configuration.kafka.KafkaHeaders
Deprecated.
KafkaHeaders(Headers, ConversionService) - 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(ConversionService) - Constructor for class io.micronaut.configuration.kafka.bind.KafkaHeadersBinder
 
KafkaHealthConfiguration - Interface in io.micronaut.configuration.kafka.config
Kafka Health indicator Configuration.
KafkaHealthConfigurationProperties - Class in io.micronaut.configuration.kafka.config
ConfigurationProperties implementation of KafkaHealthConfiguration.
KafkaHealthConfigurationProperties() - Constructor for class io.micronaut.configuration.kafka.config.KafkaHealthConfigurationProperties
 
KafkaHealthIndicator - Class in io.micronaut.configuration.kafka.health
A HealthIndicator for Kafka.
KafkaHealthIndicator(BeanContext, KafkaDefaultConfiguration, NetworkClientCreator, KafkaHealthConfiguration) - Constructor for class io.micronaut.configuration.kafka.health.KafkaHealthIndicator
Constructs a new Kafka health indicator for the given arguments.
KafkaHealthIndicator(AdminClient, KafkaDefaultConfiguration) - Constructor for class io.micronaut.configuration.kafka.health.KafkaHealthIndicator
KafkaKey - Annotation Interface 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(ConversionService) - Constructor for class io.micronaut.configuration.kafka.bind.KafkaKeyBinder
Default constructor.
KafkaListener - Annotation Interface 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<?, ?>, ConsumerRecords<?, ?>, 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.
KafkaMessage<K,V> - Class in io.micronaut.configuration.kafka
Message payload representation.
KafkaMessage(String, K, V, Integer, Long, Map<String, Object>) - Constructor for class io.micronaut.configuration.kafka.KafkaMessage
The default constructor.
KafkaMessage.Builder<K,V> - Class in io.micronaut.configuration.kafka
The message builder.
KafkaMessageHeaderBinder<T> - Class in io.micronaut.configuration.kafka.bind
Binds message headers.
KafkaMessageHeaderBinder(ConversionService) - Constructor for class io.micronaut.configuration.kafka.bind.KafkaMessageHeaderBinder
 
KafkaMessagingBodyBinder<T> - Class in io.micronaut.configuration.kafka.bind
The default binder that binds the body of a ConsumerRecord.
KafkaMessagingBodyBinder(ConversionService) - Constructor for class io.micronaut.configuration.kafka.bind.KafkaMessagingBodyBinder
Default constructor.
KafkaMetricMeterTypeBuilder - Class in io.micronaut.configuration.kafka.metrics.builder
A builder class for constructing a typed kafka meter.
KafkaMetricMeterTypeBuilder() - Constructor for class io.micronaut.configuration.kafka.metrics.builder.KafkaMetricMeterTypeBuilder
 
KafkaNewTopics - Class in io.micronaut.configuration.kafka.admin
Creates Kafka topics via AdminClient.
KafkaNewTopics(AdminClient, CreateTopicsOptions, List<NewTopic>) - Constructor for class io.micronaut.configuration.kafka.admin.KafkaNewTopics
 
KafkaPartition - Annotation Interface in io.micronaut.configuration.kafka.annotation
Parameter level annotation to indicate which parameter is bound to the Kafka Partition.
KafkaPartitionBinder<T> - Class in io.micronaut.configuration.kafka.bind
Binder for binding the parameters that is designated the KafkaPartition.
KafkaPartitionBinder(ConversionService) - Constructor for class io.micronaut.configuration.kafka.bind.KafkaPartitionBinder
Default constructor.
KafkaPartitionKey - Annotation Interface in io.micronaut.configuration.kafka.annotation
Parameter level annotation for Kafka producers to indicate which parameter to compute the Kafka Partition from.
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 registry class for Kafka Producer instances.
KafkaProducerFactory(BeanContext, SerdeRegistry, ProducerFactory) - Constructor for class io.micronaut.configuration.kafka.KafkaProducerFactory
Default constructor.
KafkaProducerMetrics - Class in io.micronaut.configuration.kafka.metrics
 
KafkaProducerMetrics(BeanLocator) - Constructor for class io.micronaut.configuration.kafka.metrics.KafkaProducerMetrics
Default constructor.
KafkaReactorUtil - Class in io.micronaut.configuration.kafka.reactor
Utility methods for working with Kafka and Reactor.
KafkaReactorUtil() - Constructor for class io.micronaut.configuration.kafka.reactor.KafkaReactorUtil
 
KafkaSeeker - Interface in io.micronaut.configuration.kafka.seek
Performs seek operations on a target consumer.
KafkaSeekOperation - Interface in io.micronaut.configuration.kafka.seek
Represents a seek operation that may be performed on a Consumer.
KafkaSeekOperation.OffsetType - Enum Class in io.micronaut.configuration.kafka.seek
Determines the interpretation of the KafkaSeekOperation.offset() value.
KafkaSeekOperations - Interface in io.micronaut.configuration.kafka.seek
Defines an interface that can be injected into KafkaListener beans so that seek operations can be eventually performed on a consumer.
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(ApplicationEventPublisher) - Constructor for class io.micronaut.configuration.kafka.streams.KafkaStreamsFactory
Default constructor.
KafkaStreamsHealth - Class in io.micronaut.configuration.kafka.streams.health
A HealthIndicator for Kafka Streams.
KafkaStreamsHealth(KafkaStreamsFactory, HealthAggregator<?>) - Constructor for class io.micronaut.configuration.kafka.streams.health.KafkaStreamsHealth
Constructor for the health check.
KafkaStreamsMetrics - Class in io.micronaut.configuration.kafka.streams.metrics
Binds Kafka Metrics to Micrometer.
KafkaStreamsMetrics(BeanLocator) - Constructor for class io.micronaut.configuration.kafka.streams.metrics.KafkaStreamsMetrics
Default constructor.
KafkaStreamsMetricsReporter - Class in io.micronaut.configuration.kafka.streams.metrics
Kafka streams specific metrics reporter which prefixes all metrics with kafka-streams.
KafkaStreamsMetricsReporter() - Constructor for class io.micronaut.configuration.kafka.streams.metrics.KafkaStreamsMetricsReporter
 
KafkaTimestamp - Annotation Interface in io.micronaut.configuration.kafka.annotation
Parameter level annotation to indicate which parameter is bound to the Kafka Producer timestamp.
key(K) - Method in class io.micronaut.configuration.kafka.KafkaMessage.Builder
 

L

LATEST - Enum constant in enum class io.micronaut.configuration.kafka.annotation.OffsetReset
Latest means that a consumer will start reading the latest consumer records.

M

maxBlock() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaClient
The maximum duration to block synchronous send operations.
MeterType - Enum Class in io.micronaut.configuration.kafka.metrics.builder
Types of meters to be created for metrics.
metric(KafkaMetric) - Method in class io.micronaut.configuration.kafka.metrics.builder.KafkaMetricMeterTypeBuilder
Builder method for setting kafka metric.
metricChange(KafkaMetric) - Method in class io.micronaut.configuration.kafka.metrics.AbstractKafkaMetricsReporter
 
metricRemoval(KafkaMetric) - Method in class io.micronaut.configuration.kafka.metrics.AbstractKafkaMetricsReporter
 

N

nack() - Method in interface io.micronaut.configuration.kafka.KafkaAcknowledgement
Kafka does not support rejection of messages explicitly.
name(String) - Method in class io.micronaut.configuration.kafka.metrics.builder.KafkaMetricMeterTypeBuilder
Builder method for setting metric name.
names() - Method in class io.micronaut.configuration.kafka.KafkaHeaders
 
NetworkClientCreator - Interface in io.micronaut.configuration.kafka.health
FunctionalInterface to instantiate a NetworkClient.
newBuilder() - Static method in class io.micronaut.configuration.kafka.metrics.builder.KafkaMetricMeterTypeBuilder
Method for creating a new builder class.
newInstance() - Static method in interface io.micronaut.configuration.kafka.seek.KafkaSeekOperations
Creates a new KafkaSeekOperations instance.
newInstance(Consumer<?, ?>) - Static method in interface io.micronaut.configuration.kafka.seek.KafkaSeeker
Creates a new KafkaSeeker with a given target Consumer.
NODE_ID_TAG - Static variable in class io.micronaut.configuration.kafka.metrics.AbstractKafkaMetricsReporter
 
NONE - Enum constant in enum class io.micronaut.configuration.kafka.annotation.ErrorStrategyValue
Deprecated.
maintain broken, but consistent behaviour with previous versions of micronaut-kafka that do not support error strategy. See https://github.com/micronaut-projects/micronaut-kafka/issues/372
NONE - Static variable in class io.micronaut.configuration.kafka.annotation.KafkaClient.Acknowledge
Don't wait for the server to acknowledge receipt.

O

offset() - Method in interface io.micronaut.configuration.kafka.seek.KafkaSeekOperation
 
offsetReset() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaListener
 
OffsetReset - Enum Class in io.micronaut.configuration.kafka.annotation
Sets the value of the auto.offset.reset property for a Kafka consumer.
offsetStrategy() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaListener
The OffsetStrategy to use for the consumer.
OffsetStrategy - Enum Class in io.micronaut.configuration.kafka.annotation
An enum representing different strategies for committing offsets to Kafka when using KafkaListener.
offsetType() - Method in interface io.micronaut.configuration.kafka.seek.KafkaSeekOperation
 
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<AbstractKafkaStreamsConfiguration>) - Method in class io.micronaut.configuration.kafka.streams.metrics.KafkaStreamsMetrics
 
onCreated(BeanCreatedEvent<Consumer<?, ?>>) - Method in class io.micronaut.configuration.kafka.tracing.brave.BraveKafkaConsumerTracingInstrumentation
 
onCreated(BeanCreatedEvent<Producer<?, ?>>) - Method in class io.micronaut.configuration.kafka.tracing.brave.BraveKafkaProducerTracingInstrumentation
 
ONE - Static variable in class io.micronaut.configuration.kafka.annotation.KafkaClient.Acknowledge
Wait for the leader to acknowledge.
onPartitionsAssigned(Collection<TopicPartition>, KafkaSeeker) - Method in interface io.micronaut.configuration.kafka.ConsumerSeekAware
A callback method the user can implement to provide handling of customized offsets on completion of a successful partition re-assignment.
onPartitionsLost(Collection<TopicPartition>) - Method in interface io.micronaut.configuration.kafka.ConsumerSeekAware
 
onPartitionsRevoked(Collection<TopicPartition>) - Method in interface io.micronaut.configuration.kafka.ConsumerSeekAware
 
onUpdate(ClusterResource) - Method in class io.micronaut.configuration.kafka.health.KafkaHealthIndicator
 

P

partition() - Method in interface io.micronaut.configuration.kafka.seek.KafkaSeekOperation
 
partition(Integer) - Method in class io.micronaut.configuration.kafka.KafkaMessage.Builder
 
PARTITION_TAG - Static variable in class io.micronaut.configuration.kafka.metrics.ConsumerKafkaMetricsReporter
 
patterns() - Element in annotation interface io.micronaut.configuration.kafka.annotation.Topic
 
pause(String) - Method in interface io.micronaut.configuration.kafka.ConsumerRegistry
Pause the consumer for the given ID.
pause(String, Collection<TopicPartition>) - Method in interface io.micronaut.configuration.kafka.ConsumerRegistry
Pause the consumer for the given ID to consume from the given topic partitions.
perform(KafkaSeekOperation) - Method in interface io.micronaut.configuration.kafka.seek.KafkaSeeker
Performs a kafka seek operation immediately.
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.
pollTimeout() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaListener
The timeout to use for calls to Consumer.poll(java.time.Duration).
prefix(String) - Method in class io.micronaut.configuration.kafka.metrics.builder.KafkaMetricMeterTypeBuilder
Builder method for setting metric prefix.
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.DefaultKafkaListenerExceptionHandlerConfigurationProperties
The default prefix used for the default Kafka listener exception handler 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.KafkaHealthConfigurationProperties
The default prefix used for Kafka Health 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.streams.KafkaStreamsConfiguration
The default streams configuration.
producerClientId() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaListener
The client id of the producer that is used for SendTo.
ProducerFactory - Interface in io.micronaut.configuration.kafka
A factory class for creating Kafka Producer instances.
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.
producerTransactionalId() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaListener
This setting applies only for the producer that is used for SendTo.
properties() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaClient
Additional properties to configure with for Consumer.
properties() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaListener
Additional properties to configure with for Consumer.

R

redelivery() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaListener
For listeners that return reactive types, message offsets are committed without blocking the consumer.
registry(MeterRegistry) - Method in class io.micronaut.configuration.kafka.metrics.builder.KafkaMetricMeterTypeBuilder
Builder method for setting a MeterRegistry.
remove(CharSequence) - Method in class io.micronaut.configuration.kafka.KafkaHeaders
 
resume(String) - Method in interface io.micronaut.configuration.kafka.ConsumerRegistry
Resume the consumer for the given ID.
resume(String, Collection<TopicPartition>) - Method in interface io.micronaut.configuration.kafka.ConsumerRegistry
Resume the consumer for the given ID to consume from the given topic partitions.
RESUME_AT_NEXT_RECORD - Enum constant in enum class io.micronaut.configuration.kafka.annotation.ErrorStrategyValue
This strategy will ignore the current error and will resume at the next offset.
RETRY - Enum constant in enum class io.micronaut.configuration.kafka.retry.ConditionalRetryBehaviourHandler.ConditionalRetryBehaviour
 
RETRY_CONDITIONALLY_EXPONENTIALLY_ON_ERROR - Enum constant in enum class io.micronaut.configuration.kafka.annotation.ErrorStrategyValue
This strategy will stop consuming subsequent records in the case of an error and will attempt to re-consume or skip the current according to the behaviour defined by the ConditionalRetryBehaviourHandler.
RETRY_CONDITIONALLY_ON_ERROR - Enum constant in enum class io.micronaut.configuration.kafka.annotation.ErrorStrategyValue
This strategy will stop consuming subsequent records in the case of an error and will attempt to re-consume or skip the current according to the behaviour defined by the ConditionalRetryBehaviourHandler.
RETRY_EXPONENTIALLY_ON_ERROR - Enum constant in enum class io.micronaut.configuration.kafka.annotation.ErrorStrategyValue
This strategy will stop consuming subsequent records in the case of an error and will attempt to re-consume the current record with exponentially growing time breaks between consumption attempts.
RETRY_ON_ERROR - Enum constant in enum class io.micronaut.configuration.kafka.annotation.ErrorStrategyValue
This strategy will stop consuming subsequent records in the case of an error and will attempt to re-consume the current record indefinitely.
retryCount() - Element in annotation interface io.micronaut.configuration.kafka.annotation.ErrorStrategy
The fixed retry count used with RETRY_ON_ERROR and RETRY_EXPONENTIALLY_ON_ERROR, RETRY_CONDITIONALLY_ON_ERROR and RETRY_CONDITIONALLY_EXPONENTIALLY_ON_ERROR ErrorStrategyValue.
retryCountValue() - Element in annotation interface io.micronaut.configuration.kafka.annotation.ErrorStrategy
The dynamic retry count used with RETRY_ON_ERROR and RETRY_EXPONENTIALLY_ON_ERROR ErrorStrategyValue.
retryDelay() - Element in annotation interface io.micronaut.configuration.kafka.annotation.ErrorStrategy
The delay used with RETRY_ON_ERROR, RETRY_EXPONENTIALLY_ON_ERROR, RETRY_CONDITIONALLY_ON_ERROR and RETRY_CONDITIONALLY_EXPONENTIALLY_ON_ERROR ErrorStrategyValue.

S

seek(TopicPartition, long) - Static method in interface io.micronaut.configuration.kafka.seek.KafkaSeekOperation
Creates an absolute seek operation.
seekBackward(TopicPartition, long) - Static method in interface io.micronaut.configuration.kafka.seek.KafkaSeekOperation
Creates a backward seek operation.
seekForward(TopicPartition, long) - Static method in interface io.micronaut.configuration.kafka.seek.KafkaSeekOperation
Creates a forward seek operation.
seekPastDeserializationError(SerializationException, Object, Consumer<?, ?>) - Method in class io.micronaut.configuration.kafka.exceptions.DefaultKafkaListenerExceptionHandler
Seeks past a serialization exception if an error occurs.
seekRelativeToBeginning(TopicPartition, long) - Static method in interface io.micronaut.configuration.kafka.seek.KafkaSeekOperation
Creates a seek operation relative to the beginning.
seekRelativeToEnd(TopicPartition, long) - Static method in interface io.micronaut.configuration.kafka.seek.KafkaSeekOperation
Creates a seek operation relative to the end.
seekToBeginning(Collection<TopicPartition>) - Static method in interface io.micronaut.configuration.kafka.seek.KafkaSeekOperation
Creates a list of seek to the beginning operations.
seekToBeginning(TopicPartition) - Static method in interface io.micronaut.configuration.kafka.seek.KafkaSeekOperation
Creates a seek to the beginning operation.
seekToEnd(Collection<TopicPartition>) - Static method in interface io.micronaut.configuration.kafka.seek.KafkaSeekOperation
Creates a list of seek to the end operations.
seekToEnd(TopicPartition) - Static method in interface io.micronaut.configuration.kafka.seek.KafkaSeekOperation
Creates a seek to the end operation.
seekToTimestamp(Collection<TopicPartition>, long) - Static method in interface io.micronaut.configuration.kafka.seek.KafkaSeekOperation
Creates a list of seek to the timestamp operations.
seekToTimestamp(TopicPartition, long) - Static method in interface io.micronaut.configuration.kafka.seek.KafkaSeekOperation
Creates a seek to the timestamp operation.
SEND_TO_TRANSACTION - Enum constant in enum class io.micronaut.configuration.kafka.annotation.OffsetStrategy
Only applicable for transactional processing in combination with SendTo.
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.JsonObjectSerde
 
serializer() - Method in class io.micronaut.configuration.kafka.serde.JsonObjectSerde
 
sessionTimeout() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaListener
The session timeout for a consumer.
setCloseTimeout(Duration) - Method in class io.micronaut.configuration.kafka.streams.AbstractKafkaStreamsConfiguration
 
setCommitRecordOnDeserializationFailure(boolean) - Method in class io.micronaut.configuration.kafka.config.DefaultKafkaListenerExceptionHandlerConfigurationProperties
Whether to commit record on deserialization failure.
setCommitRecordOnDeserializationFailure(boolean) - Method in class io.micronaut.configuration.kafka.exceptions.DefaultKafkaListenerExceptionHandler
Sets whether to commit the offset of past records that are not deserializable and are skipped.
setEnabled(boolean) - Method in class io.micronaut.configuration.kafka.config.KafkaHealthConfigurationProperties
Whether the Kafka health check is enabled.
setExecutor(String) - Method in class io.micronaut.configuration.kafka.config.AbstractKafkaProducerConfiguration
Sets the default executor to use to enable non-blocking producers.
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.
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.
setName(String) - Method in class io.micronaut.configuration.kafka.streams.AbstractKafkaStreamsConfiguration
 
setRestricted(boolean) - Method in class io.micronaut.configuration.kafka.config.KafkaHealthConfigurationProperties
By default, the health check requires cluster-wide permissions in order to get information about the nodes in the Kafka cluster.
setSkipRecordOnDeserializationFailure(boolean) - Method in class io.micronaut.configuration.kafka.config.DefaultKafkaListenerExceptionHandlerConfigurationProperties
Whether to skip record on deserialization failure.
setSkipRecordOnDeserializationFailure(boolean) - Method in class io.micronaut.configuration.kafka.exceptions.DefaultKafkaListenerExceptionHandler
Sets whether the seek past records that are not deserializable.
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.
SKIP - Enum constant in enum class io.micronaut.configuration.kafka.retry.ConditionalRetryBehaviourHandler.ConditionalRetryBehaviour
 
stop() - Method in class io.micronaut.configuration.kafka.KafkaProducerFactory
Shuts down any existing clients.
SYNC - Enum constant in enum class io.micronaut.configuration.kafka.annotation.OffsetStrategy
Synchronously commit offsets using Consumer.commitSync() after each batch of messages is processed.
SYNC_PER_RECORD - Enum constant in enum class io.micronaut.configuration.kafka.annotation.OffsetStrategy
Synchronously commit offsets using Consumer.commitSync() after each ConsumerRecord is processed.

T

tagFunction(Function<MetricName, List<Tag>>) - Method in class io.micronaut.configuration.kafka.metrics.builder.KafkaMetricMeterTypeBuilder
Builder method for setting function to get tags.
threads() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaListener
Statically configure the number of threads of a Kafka consumer.
threadsValue() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaListener
Dynamically configure the number of threads of a Kafka consumer.
TIME_GAUGE - Enum constant in enum class io.micronaut.configuration.kafka.metrics.builder.MeterType
 
timestamp() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaClient
Whether to include timestamps in outgoing messages.
timestamp(Long) - Method in class io.micronaut.configuration.kafka.KafkaMessage.Builder
 
TIMESTAMP - Enum constant in enum class io.micronaut.configuration.kafka.seek.KafkaSeekOperation.OffsetType
The offset represents a Kafka timestamp.
toKafkaProperties(Environment, Map<?, ?>) - Static method in class io.micronaut.configuration.kafka.config.AbstractKafkaConfiguration
Convert the given map of values to kafka properties.
topic() - Method in interface io.micronaut.configuration.kafka.seek.KafkaSeekOperation
 
topic(String) - Method in class io.micronaut.configuration.kafka.KafkaMessage.Builder
 
Topic - Annotation Interface in io.micronaut.configuration.kafka.annotation
Method level annotation used to specify which topics should be subscribed to.
TOPIC_TAG - Static variable in class io.micronaut.configuration.kafka.metrics.AbstractKafkaMetricsReporter
 
topicPartition() - Method in interface io.micronaut.configuration.kafka.seek.KafkaSeekOperation
 
Topics - Annotation Interface in io.micronaut.configuration.kafka.annotation
Repeatable annotation for one or many Topic annotations.
TOPICS - Static variable in class io.micronaut.configuration.kafka.config.AbstractKafkaConfiguration
The topics that should be created.
toString() - Method in class io.micronaut.configuration.kafka.serde.JsonObjectSerde
 
transactionalId() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaClient
The TransactionalId to use for transactional delivery.
TransactionalProducerRegistry - Interface in io.micronaut.configuration.kafka
A registry of managed transactional Producer instances key by id and type.
TYPE - Static variable in class io.micronaut.configuration.kafka.bind.KafkaHeadersBinder
 
TypedConsumerRecordBinder<T> - Interface in io.micronaut.configuration.kafka.bind
Allows binding by type.

U

uniqueGroupId() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaListener
A unique string (UUID) can be appended to the group ID.

V

value() - Element in annotation interface io.micronaut.configuration.kafka.annotation.ErrorStrategy
The strategy to use when an error occurs, see ErrorStrategyValue.
value() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaClient
value() - Element in annotation interface io.micronaut.configuration.kafka.annotation.KafkaListener
Sets the consumer group id of the Kafka consumer.
value() - Element in annotation interface io.micronaut.configuration.kafka.annotation.Topic
 
value() - Element in annotation interface io.micronaut.configuration.kafka.annotation.Topics
 
valueOf(String) - Static method in enum class io.micronaut.configuration.kafka.annotation.ErrorStrategyValue
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.micronaut.configuration.kafka.annotation.OffsetReset
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.micronaut.configuration.kafka.annotation.OffsetStrategy
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.micronaut.configuration.kafka.metrics.builder.MeterType
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.micronaut.configuration.kafka.retry.ConditionalRetryBehaviourHandler.ConditionalRetryBehaviour
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.micronaut.configuration.kafka.seek.KafkaSeekOperation.OffsetType
Returns the enum constant of this class with the specified name.
values() - Static method in enum class io.micronaut.configuration.kafka.annotation.ErrorStrategyValue
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.micronaut.configuration.kafka.annotation.OffsetReset
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.micronaut.configuration.kafka.annotation.OffsetStrategy
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Method in class io.micronaut.configuration.kafka.KafkaHeaders
 
values() - Static method in enum class io.micronaut.configuration.kafka.metrics.builder.MeterType
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.micronaut.configuration.kafka.retry.ConditionalRetryBehaviourHandler.ConditionalRetryBehaviour
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.micronaut.configuration.kafka.seek.KafkaSeekOperation.OffsetType
Returns an array containing the constants of this enum class, in the order they are declared.

W

withBody(F) - Static method in class io.micronaut.configuration.kafka.KafkaMessage.Builder
 
withoutBody() - Static method in class io.micronaut.configuration.kafka.KafkaMessage.Builder
 
A B C D E F G H I J K L M N O P R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form