Index
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 eachConsumerRecord
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.
- 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
-
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 underlyingConsumer
. - ConsumerExecutorServiceConfig - Class in io.micronaut.configuration.kafka.executor
-
Configures a
ScheduledExecutorService
for runningKafkaListener
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 performseek operations
when the set of partitions assigned to theConsumer
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_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_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
. - 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 aConsumerRecord
. - 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 ofDefaultKafkaListenerExceptionHandlerConfiguration
. - 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 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. - 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, see
ErrorStrategyValue
.
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
- 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. - 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. - 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
-
The same as
KafkaListener.value()
.
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
- 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.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
- 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
andDeserializer
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 computesSerde
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 ofKafkaHealthConfiguration
. - 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
-
Deprecated, for removal: This API element is subject to removal in a future version.
- 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 aKafkaListener
. - 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 aConsumer
. - 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 thatseek 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 aNetworkClient
. - 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 targetConsumer
. - 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_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
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 and RETRY_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.
- 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.
- 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.
- 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.
- 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 eachConsumerRecord
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
-
Same as
KafkaClient.id()
. - 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.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.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
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form