Index (kafka 1.1.1 API)

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

A

AbstractKafkaConfiguration<K,V> - Class in io.micronaut.configuration.kafka.config: An abstract Kafka configuration class.
AbstractKafkaConfiguration(Properties) - Constructor for class io.micronaut.configuration.kafka.config.AbstractKafkaConfiguration: Constructs a new instance.
AbstractKafkaConsumerConfiguration<K,V> - Class in io.micronaut.configuration.kafka.config: Abstract Configuration for Apache Kafka Consumer.
AbstractKafkaConsumerConfiguration(Properties) - Constructor for class io.micronaut.configuration.kafka.config.AbstractKafkaConsumerConfiguration: Constructs a new instance.
AbstractKafkaProducerConfiguration<K,V> - Class in io.micronaut.configuration.kafka.config: Abstract Configuration for Apache Kafka Producer.
AbstractKafkaProducerConfiguration(Properties) - Constructor for class io.micronaut.configuration.kafka.config.AbstractKafkaProducerConfiguration: Constructs a new instance.
AbstractKafkaStreamsConfiguration<K,V> - Class in io.micronaut.configuration.kafka.streams: Abstract streams configuration.
AbstractKafkaStreamsConfiguration(KafkaDefaultConfiguration) - Constructor for class io.micronaut.configuration.kafka.streams.AbstractKafkaStreamsConfiguration: Construct a new KafkaStreamsConfiguration for the given defaults.
ack() - Method in interface io.micronaut.configuration.kafka.Acknowledgement: Deprecated.

Acknowledge the last ConsumerRecord synchronously.
Acknowledge() - Constructor for class io.micronaut.configuration.kafka.annotation.KafkaClient.Acknowledge
Acknowledgement - Interface in io.micronaut.configuration.kafka: Deprecated.
Use Acknowledgement instead
add(CharSequence, CharSequence) - Method in class io.micronaut.configuration.kafka.KafkaHeaders
AdminClientFactory - Class in io.micronaut.configuration.kafka.admin: Creates the Kakfa AdminClient.
AdminClientFactory() - Constructor for class io.micronaut.configuration.kafka.admin.AdminClientFactory
ALL - Static variable in class io.micronaut.configuration.kafka.annotation.KafkaClient.Acknowledge: Wait for a full set of in-sync replicas to acknowledge.
AnnotatedConsumerRecordBinder<A extends java.lang.annotation.Annotation,T> - Interface in io.micronaut.configuration.kafka.bind: Interface for binders that bind method arguments from a ConsumerRecord via a annotation.
annotationType() - Method in interface io.micronaut.configuration.kafka.bind.AnnotatedConsumerRecordBinder
annotationType() - Method in class io.micronaut.configuration.kafka.bind.KafkaBodyBinder
annotationType() - Method in class io.micronaut.configuration.kafka.bind.KafkaHeaderBinder
annotationType() - Method in class io.micronaut.configuration.kafka.bind.KafkaKeyBinder
annotationType() - Method in class io.micronaut.configuration.kafka.bind.KafkaMessagingBodyBinder
annotationType() - Method in class io.micronaut.configuration.kafka.scope.KafkaClientScope
argumentType() - Method in class io.micronaut.configuration.kafka.bind.KafkaHeadersBinder

B

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

C

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

D

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

E

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

F

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

G

get(CharSequence) - Method in class io.micronaut.configuration.kafka.KafkaHeaders
get(CharSequence, ArgumentConversionContext<T>) - Method in class io.micronaut.configuration.kafka.KafkaHeaders
get(BeanResolutionContext, BeanDefinition<T>, BeanIdentifier, Provider<T>) - Method in class io.micronaut.configuration.kafka.scope.KafkaClientScope
getAll(CharSequence) - Method in class io.micronaut.configuration.kafka.KafkaHeaders
getConfig() - Method in class io.micronaut.configuration.kafka.config.AbstractKafkaConfiguration
getConfiguration() - Method in class io.micronaut.configuration.kafka.streams.ConfiguredStreamBuilder: The configuration.
getConsumer(String) - Method in interface io.micronaut.configuration.kafka.ConsumerRegistry: Returns a managed Consumer.
getConsumer(String) - Method in class io.micronaut.configuration.kafka.processor.KafkaConsumerProcessor
getConsumerIds() - Method in interface io.micronaut.configuration.kafka.ConsumerRegistry: The IDs of the available consumers.
getConsumerIds() - Method in class io.micronaut.configuration.kafka.processor.KafkaConsumerProcessor
getConsumerRecord() - Method in exception io.micronaut.configuration.kafka.exceptions.KafkaListenerException
getDeserializer(Class<T>) - Method in interface io.micronaut.configuration.kafka.serde.SerdeRegistry: Obtain a Deserializer for the given type.
getHealthTimeout() - Method in class io.micronaut.configuration.kafka.config.KafkaDefaultConfiguration: The health check timeout.
getKafkaConsumer() - Method in exception io.micronaut.configuration.kafka.exceptions.KafkaListenerException
getKafkaListener() - Method in exception io.micronaut.configuration.kafka.exceptions.KafkaListenerException
getKafkaServer() - Method in class io.micronaut.configuration.kafka.embedded.KafkaEmbedded: Return the configured Kafka server is it was configured.
getKeyDeserializer() - Method in class io.micronaut.configuration.kafka.config.AbstractKafkaConsumerConfiguration
getKeySerializer() - Method in class io.micronaut.configuration.kafka.config.AbstractKafkaProducerConfiguration
getMetricPrefix() - Method in class io.micronaut.configuration.kafka.metrics.ConsumerKafkaMetricsReporter: Abstract method to implement with the metric prefix for the reporter.
getMetricPrefix() - Method in class io.micronaut.configuration.kafka.metrics.ProducerKafkaMetricsReporter: Abstract method to implement with the metric prefix for the reporter.
getProducer(String, Argument<K>, Argument<V>) - Method in interface io.micronaut.configuration.kafka.KafkaProducerRegistry: Deprecated.

Returns a managed Producer.
getProducer(String, Argument<K>, Argument<V>) - Method in interface io.micronaut.configuration.kafka.ProducerRegistry: Returns a managed Producer.
getProducer(String, Argument<K>, Argument<V>) - Method in class io.micronaut.configuration.kafka.scope.KafkaClientScope
getProperties() - Method in class io.micronaut.configuration.kafka.embedded.KafkaEmbeddedConfiguration
getResult() - Method in class io.micronaut.configuration.kafka.health.KafkaHealthIndicator
getSerde(Class<T>) - Method in class io.micronaut.configuration.kafka.serde.CompositeSerdeRegistry
getSerde(Class<T>) - Method in class io.micronaut.configuration.kafka.serde.JsonSerdeRegistry
getSerde(Class<T>) - Method in interface io.micronaut.configuration.kafka.serde.SerdeRegistry: Obtain a Serde for the given type.
getSerializer(Class<T>) - Method in interface io.micronaut.configuration.kafka.serde.SerdeRegistry: Obtain a Serializer for the given type.
getTopics() - Method in class io.micronaut.configuration.kafka.embedded.KafkaEmbeddedConfiguration
getValueDeserializer() - Method in class io.micronaut.configuration.kafka.config.AbstractKafkaConsumerConfiguration
getValueSerializer() - Method in class io.micronaut.configuration.kafka.config.AbstractKafkaProducerConfiguration
getZkPort() - Method in class io.micronaut.configuration.kafka.embedded.KafkaEmbedded: Returns the port Zookeeper is running on if it was created.
getZkUtils() - Method in class io.micronaut.configuration.kafka.embedded.KafkaEmbedded: Returns the Zookeeper tools if they are available.

H

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

I

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

J

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

K

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

N

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

O

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

P

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

R

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

S

seekPastDeserializationError(SerializationException, Object, Consumer<?, ?>) - Method in class io.micronaut.configuration.kafka.exceptions.DefaultKafkaListenerExceptionHandler: Seeks past a serialization exception if an error occurs.
SerdeRegistry - Interface in io.micronaut.configuration.kafka.serde: A registry of Kafka Serde instances.
serialize(String, T) - Method in class io.micronaut.configuration.kafka.serde.JsonSerde
serializer() - Method in class io.micronaut.configuration.kafka.serde.JsonSerde
setEnabled(boolean) - Method in class io.micronaut.configuration.kafka.embedded.KafkaEmbeddedConfiguration: Sets whether the embedded Kafka server is enabled.
setHealthTimeout(Duration) - Method in class io.micronaut.configuration.kafka.config.KafkaDefaultConfiguration: The health check timeout.
setKafkaConsumer(Consumer<K, V>) - Method in interface io.micronaut.configuration.kafka.ConsumerAware: Called when the underlying Consumer is created.
setKafkaConsumer(KafkaConsumer<K, V>) - Method in interface io.micronaut.configuration.kafka.KafkaConsumerAware: Deprecated.

Called when the underlying KafkaConsumer is created.
setKafkaConsumer(Consumer<K, V>) - Method in interface io.micronaut.configuration.kafka.KafkaConsumerAware: Deprecated.
setKeyDeserializer(Deserializer<K>) - Method in class io.micronaut.configuration.kafka.config.AbstractKafkaConsumerConfiguration: Sets the key deserializer.
setKeySerializer(Serializer<K>) - Method in class io.micronaut.configuration.kafka.config.AbstractKafkaProducerConfiguration: Sets the key serializer.
setProperties(Properties) - Method in class io.micronaut.configuration.kafka.embedded.KafkaEmbeddedConfiguration: Sets the broker properties.
setSkipRecordOnDeserializationFailure(boolean) - Method in class io.micronaut.configuration.kafka.exceptions.DefaultKafkaListenerExceptionHandler: Sets whether the seek past records that are not deserializable.
setTopics(List<String>) - Method in class io.micronaut.configuration.kafka.embedded.KafkaEmbeddedConfiguration: The topics that should be created by the embedded instance.
setValueDeserializer(Deserializer<V>) - Method in class io.micronaut.configuration.kafka.config.AbstractKafkaConsumerConfiguration: Sets the default value deserializer.
setValueSerializer(Serializer<V>) - Method in class io.micronaut.configuration.kafka.config.AbstractKafkaProducerConfiguration: Sets the default value serializer.
stop() - Method in class io.micronaut.configuration.kafka.scope.KafkaClientScope

T

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

V

valueOf(String) - Static method in enum io.micronaut.configuration.kafka.annotation.OffsetReset: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum io.micronaut.configuration.kafka.annotation.OffsetStrategy: Returns the enum constant of this type with the specified name.
values() - Static method in enum io.micronaut.configuration.kafka.annotation.OffsetReset: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum io.micronaut.configuration.kafka.annotation.OffsetStrategy: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Method in class io.micronaut.configuration.kafka.KafkaHeaders

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